Package org.apache.activemq.artemis.utils.actors

Class OrderedExecutor

java.lang.Object

org.apache.activemq.artemis.utils.actors.HandlerBase

org.apache.activemq.artemis.utils.actors.ProcessorBase<Runnable>

org.apache.activemq.artemis.utils.actors.OrderedExecutor

All Implemented Interfaces:

Executor, ArtemisExecutor

public class OrderedExecutor
extends ProcessorBase<Runnable>
implements ArtemisExecutor

An executor that always runs all tasks in order, using a delegate executor to run the tasks.

More specifically, any call B to the execute(Runnable) method that happens-after another call A to the same method, will result in B's task running after A's.

Field Summary

Fields inherited from class org.apache.activemq.artemis.utils.actors.ProcessorBase

requestedShutdown, STATE_FORCED_SHUTDOWN, STATE_NOT_RUNNING, STATE_RUNNING, tasks

Constructor Summary

Constructors

Constructor	Description
OrderedExecutor(Executor delegate)

Method Summary

Modifier and Type	Method	Description
protected final void	doTask(Runnable task)
final void	execute(Runnable run)
boolean	isFair()
OrderedExecutor	setFair(boolean fair)	If this OrderedExecutor is fair, it will yield for another executors after each task ran
String	toString()

Methods inherited from class org.apache.activemq.artemis.utils.actors.ProcessorBase

flush, flush, isFlushed, remaining, shutdown, shutdown, shutdownNow, status, task, yield

Methods inherited from class org.apache.activemq.artemis.utils.actors.HandlerBase

enter, inHandler, leave

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.activemq.artemis.utils.actors.ArtemisExecutor

flush, inHandler, isFlushed, shutdown, shutdownNow, shutdownNow, yield

Constructor Details

OrderedExecutor

public OrderedExecutor(Executor delegate)

Method Details

isFair

public boolean isFair()

Specified by:

isFair in interface ArtemisExecutor

setFair

public OrderedExecutor setFair(boolean fair)

If this OrderedExecutor is fair, it will yield for another executors after each task ran

Specified by:

setFair in interface ArtemisExecutor

doTask

protected final void doTask(Runnable task)

Specified by:

doTask in class ProcessorBase<Runnable>

execute

public final void execute(Runnable run)

Specified by:

execute in interface Executor

toString

public String toString()

Overrides:

toString in class Object