Package org.apache.activemq.thread
Class DeterministicTaskRunner
- java.lang.Object
-
- org.apache.activemq.thread.DeterministicTaskRunner
-
- All Implemented Interfaces:
TaskRunner
public class DeterministicTaskRunner extends Object implements TaskRunner
-
-
Constructor Summary
Constructors Constructor Description DeterministicTaskRunner(Executor executor, Task task)Constructor
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidshutdown()voidshutdown(long timeout)shut down the taskvoidwakeup()We Expect MANY wakeup calls on the same TaskRunner - but each needs to run
-
-
-
Method Detail
-
wakeup
public void wakeup() throws InterruptedExceptionWe Expect MANY wakeup calls on the same TaskRunner - but each needs to run- Specified by:
wakeupin interfaceTaskRunner- Throws:
InterruptedException
-
shutdown
public void shutdown(long timeout) throws InterruptedExceptionshut down the task- Specified by:
shutdownin interfaceTaskRunner- Throws:
InterruptedException
-
shutdown
public void shutdown() throws InterruptedException- Specified by:
shutdownin interfaceTaskRunner- Throws:
InterruptedException
-
-