org.apache.activemq.thread
Class DeterministicTaskRunner

java.lang.Object
  extended by org.apache.activemq.thread.DeterministicTaskRunner
All Implemented Interfaces:
TaskRunner

public class DeterministicTaskRunner
extends java.lang.Object
implements TaskRunner


Constructor Summary
DeterministicTaskRunner(java.util.concurrent.Executor executor, Task task)
          Constructor
 
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
 

Constructor Detail

DeterministicTaskRunner

public DeterministicTaskRunner(java.util.concurrent.Executor executor,
                               Task task)
Constructor

Parameters:
executor -
task -
Method Detail

wakeup

public void wakeup()
            throws java.lang.InterruptedException
We Expect MANY wakeup calls on the same TaskRunner - but each needs to run

Specified by:
wakeup in interface TaskRunner
Throws:
java.lang.InterruptedException

shutdown

public void shutdown(long timeout)
              throws java.lang.InterruptedException
shut down the task

Specified by:
shutdown in interface TaskRunner
Throws:
java.lang.InterruptedException

shutdown

public void shutdown()
              throws java.lang.InterruptedException
Specified by:
shutdown in interface TaskRunner
Throws:
java.lang.InterruptedException


Copyright © 2005-2012. All Rights Reserved.