private class DummyTransport.QueueProcessor extends java.lang.Object implements WorkerTask
| Modifier and Type | Field and Description |
|---|---|
private java.util.Queue<DummyTransport.MessageContainer> |
queue |
private boolean |
stop |
private AbstractTransportMapping |
tm |
| Constructor and Description |
|---|
QueueProcessor(java.util.Queue<DummyTransport.MessageContainer> queue,
AbstractTransportMapping tm) |
| Modifier and Type | Method and Description |
|---|---|
void |
interrupt()
Interrupts this task.
|
void |
join()
Waits until this task has been finished.
|
void |
run() |
void |
terminate()
The
WorkerPool might call this method to hint the active
WorkTask instance to complete execution as soon as possible. |
private volatile boolean stop
private java.util.Queue<DummyTransport.MessageContainer> queue
private AbstractTransportMapping tm
public QueueProcessor(java.util.Queue<DummyTransport.MessageContainer> queue, AbstractTransportMapping tm)
public void run()
run in interface java.lang.Runnablepublic void terminate()
WorkerTaskWorkerPool might call this method to hint the active
WorkTask instance to complete execution as soon as possible.terminate in interface WorkerTaskpublic void join()
throws java.lang.InterruptedException
WorkerTaskjoin in interface WorkerTaskjava.lang.InterruptedExceptionpublic void interrupt()
WorkerTaskinterrupt in interface WorkerTaskThread.interrupt()