org.apache.activemq.thread
Class DeterministicTaskRunner

java.lang.Object
  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