org.apache.activemq.thread
Class DeterministicTaskRunner

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

public class DeterministicTaskRunner
extends Object
implements TaskRunner


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

Parameters:
executor -
task -
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 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-2012 The Apache Software Foundation. All Rights Reserved.