wt.queue
Class ScheduleQueueThread

java.lang.Object
  java.lang.Thread
      wt.queue.ScheduleQueueThread

All Implemented Interfaces:

Runnable

public class ScheduleQueueThread

extends Thread

Field Summary

private boolean	bye
static int	DEFAULT_WAIT_TIME
private boolean	missedEntries
private WtQueue	qu
private QueueMonitorHelper	queueMonitorHelper
private String	queueSignal
static boolean	VERBOSE
private long	waitTime

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

ScheduleQueueThread(WtQueue q)

Method Summary

private long	getNextWaitTime(long time)
private long	nextWaitTime()
void	poke()
private void	processReadyEntries()
void	run()
private void	saveNextProcessTime(Timestamp t)
void	setExit()
void	setQueue(WtQueue queue)

Methods inherited from class java.lang.Thread

activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getContextClassLoader, getName, getPriority, getThreadGroup, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setName, setPriority, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Detail

qu

private WtQueue qu

queueSignal

private String queueSignal

waitTime

private long waitTime

bye

private boolean bye

missedEntries

private boolean missedEntries

queueMonitorHelper

private QueueMonitorHelper queueMonitorHelper

VERBOSE

public static boolean VERBOSE

DEFAULT_WAIT_TIME

public static final int DEFAULT_WAIT_TIME

See Also:

Constant Field Values

Constructor Detail

ScheduleQueueThread

public ScheduleQueueThread(WtQueue q)

Method Detail

poke

public void poke()

run

public void run()

getNextWaitTime

private long getNextWaitTime(long time)

nextWaitTime

private long nextWaitTime()

saveNextProcessTime

private void saveNextProcessTime(Timestamp t)
                          throws WTException

Throws:

WTException

processReadyEntries

private void processReadyEntries()

setExit

public void setExit()

setQueue

public void setQueue(WtQueue queue)