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
- Version:
- $Revision: 1.1 $
Method Summary |
void |
shutdown()
|
void |
shutdown(long timeout)
shut down the task |
void |
wakeup()
We Expect MANY wakeup calls on the same TaskRunner - but each
needs to run |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
DeterministicTaskRunner
public DeterministicTaskRunner(Executor executor,
Task task)
- Constructor
- Parameters:
executor
- task
-
wakeup
public void wakeup()
throws InterruptedException
- We Expect MANY wakeup calls on the same TaskRunner - but each
needs to run
- Specified by:
wakeup
in interface TaskRunner
- Throws:
InterruptedException
shutdown
public void shutdown(long timeout)
throws InterruptedException
- shut down the task
- Specified by:
shutdown
in interface TaskRunner
- Throws:
InterruptedException
shutdown
public void shutdown()
throws InterruptedException
- Specified by:
shutdown
in interface TaskRunner
- Throws:
InterruptedException
Copyright © 2005-2011 Apache Software Foundation. All Rights Reserved.