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 void
shutdown()
void
shutdown(long timeout)
shut down the taskvoid
wakeup()
We Expect MANY wakeup calls on the same TaskRunner - but each needs to run
-
-
-
Method Detail
-
wakeup
public void wakeup() throws InterruptedException
We Expect MANY wakeup calls on the same TaskRunner - but each needs to run- Specified by:
wakeup
in interfaceTaskRunner
- Throws:
InterruptedException
-
shutdown
public void shutdown(long timeout) throws InterruptedException
shut down the task- Specified by:
shutdown
in interfaceTaskRunner
- Throws:
InterruptedException
-
shutdown
public void shutdown() throws InterruptedException
- Specified by:
shutdown
in interfaceTaskRunner
- Throws:
InterruptedException
-
-