reactor.event.dispatch

Class AbstractMultiThreadDispatcher

java.lang.Object

reactor.event.dispatch.AbstractLifecycleDispatcher

reactor.event.dispatch.AbstractMultiThreadDispatcher

All Implemented Interfaces:

java.util.concurrent.Executor, Dispatcher

Direct Known Subclasses:

ThreadPoolExecutorDispatcher, WorkQueueDispatcher

public abstract class AbstractMultiThreadDispatcher
extends AbstractLifecycleDispatcher

Base implementation for multi-threaded dispatchers

Since:

1.1

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractMultiThreadDispatcher.MultiThreadTask

Nested classes/interfaces inherited from class reactor.event.dispatch.AbstractLifecycleDispatcher

AbstractLifecycleDispatcher.Task

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractMultiThreadDispatcher(int numberThreads, int backlog)

Method Summary

Modifier and Type	Method and Description
protected void	addToTailRecursionPile(AbstractLifecycleDispatcher.Task task)
protected AbstractLifecycleDispatcher.Task	allocateRecursiveTask()
protected AbstractLifecycleDispatcher.Task	allocateTask()
int	getBacklog()

Methods inherited from class reactor.event.dispatch.AbstractLifecycleDispatcher

alive, awaitAndShutdown, dispatch, dispatch, execute, execute, getContext, halt, isInContext, route, shutdown

Methods inherited from class java.lang.Object

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

Methods inherited from interface reactor.event.dispatch.Dispatcher

awaitAndShutdown

Constructor Detail

AbstractMultiThreadDispatcher

protected AbstractMultiThreadDispatcher(int numberThreads,
                                        int backlog)

Method Detail

getBacklog

public int getBacklog()

allocateRecursiveTask

protected AbstractLifecycleDispatcher.Task allocateRecursiveTask()

Specified by:

allocateRecursiveTask in class AbstractLifecycleDispatcher

addToTailRecursionPile

protected void addToTailRecursionPile(AbstractLifecycleDispatcher.Task task)

Overrides:

addToTailRecursionPile in class AbstractLifecycleDispatcher

allocateTask

protected AbstractLifecycleDispatcher.Task allocateTask()

Specified by:

allocateTask in class AbstractLifecycleDispatcher