|
JBoss API: Class WorkerQueue
org.jboss.util
|
Inner Class Summary | |
protected class |
WorkerQueue.QueueLoop
Class that loops getting the next job to be executed and then executing it, in the worker thread. |
Field Summary | |
protected java.lang.Thread |
m_queueThread
|
Constructor Summary | |
WorkerQueue()
Creates a new worker queue with default thread name of "Worker Thread" |
|
WorkerQueue(java.lang.String threadName)
Creates a new worker queue with the specified thread name |
|
WorkerQueue(java.lang.String threadName,
boolean isDaemon)
Creates a new worker queue with the specified thread name |
Method Summary | |
protected void |
clear()
Clears the running thread after the queue has been stopped. |
protected java.lang.Runnable |
createQueueLoop()
Creates the loop that will get the next job and process it. |
protected Executable |
getJob()
Called by this class, this method checks if the queue is empty; if it is, then waits, else returns the current job. |
protected Executable |
getJobImpl()
Never call this method, only override in subclasses to perform job getting in a specific way, normally tied to the data structure holding the jobs. |
protected boolean |
isInterrupted()
Returns whether the worker thread has been interrupted. |
protected void |
logJobException(java.lang.Exception x)
Logs exceptions that happens during the execution of a job. |
void |
putJob(Executable job)
Called by a thread that is not the WorkerQueue thread, this method queues the job and, if necessary, wakes up this worker queue that is waiting in getJob() . |
protected void |
putJobImpl(Executable job)
Never call this method, only override in subclasses to perform job adding in a specific way, normally tied to the data structure holding the jobs. |
void |
start()
Starts the worker queue. |
void |
stop()
Stops nicely the worker queue. |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
protected java.lang.Thread m_queueThread
Constructor Detail |
public WorkerQueue()
public WorkerQueue(java.lang.String threadName)
public WorkerQueue(java.lang.String threadName, boolean isDaemon)
Method Detail |
public void start()
stop()
public void stop()
clear()
,
start()
,
isInterrupted()
public void putJob(Executable job)
getJob()
.protected boolean isInterrupted()
stop()
protected Executable getJob() throws java.lang.InterruptedException
putJob(org.jboss.util.Executable)
protected Executable getJobImpl() throws java.lang.InterruptedException
protected void putJobImpl(Executable job)
protected void clear()
protected java.lang.Runnable createQueueLoop()
protected void logJobException(java.lang.Exception x)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: INNER | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |