public final class Worker
extends java.lang.Thread
| Constructor and Description |
|---|
Worker()
Creates a new worker.
|
| Modifier and Type | Method and Description |
|---|---|
void |
finish()
Kills the worker after he completed his work.
|
WorkerPool |
getWorkerPool()
Returns the worker's assigned pool.
|
java.lang.Runnable |
getWorkload()
Returns the workload object.
|
boolean |
isAvailable()
Checks, whether this worker has some work to do.
|
boolean |
isFinish()
Checks whether this worker has received the signal to finish and die.
|
void |
run()
If a workload is set, process it.
|
void |
setWorkerPool(WorkerPool workerPool)
Defines the worker's assigned pool.
|
void |
setWorkload(java.lang.Runnable r)
Set the next workload for this worker.
|
activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yieldpublic void setWorkload(java.lang.Runnable r)
r - the next workload for the worker.java.lang.IllegalStateException - if the worker is not idle.public java.lang.Runnable getWorkload()
public void finish()
public boolean isAvailable()
public void run()
run in interface java.lang.Runnablerun in class java.lang.Threadpublic boolean isFinish()
public WorkerPool getWorkerPool()
public void setWorkerPool(WorkerPool workerPool)
workerPool - the worker pool (or null, if the worker is not assigned to a
pool).