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

Constructors

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

Method Summary

Methods

Modifier and Type	Method and Description
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