reactor.event.dispatch

Class AbstractSingleThreadDispatcher

java.lang.Object

reactor.event.dispatch.AbstractLifecycleDispatcher

reactor.event.dispatch.AbstractSingleThreadDispatcher

All Implemented Interfaces:

java.util.concurrent.Executor, Dispatcher

Direct Known Subclasses:

RingBufferDispatcher

public abstract class AbstractSingleThreadDispatcher
extends AbstractLifecycleDispatcher

Base Implementation for single-threaded Dispatchers.

Since:

1.1

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractSingleThreadDispatcher.SingleThreadTask

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

AbstractLifecycleDispatcher.Task

Constructor Summary

Constructors

Constructor and Description
AbstractSingleThreadDispatcher(int backlog)

Method Summary

Modifier and Type	Method and Description
protected AbstractLifecycleDispatcher.Task	allocateRecursiveTask()
protected abstract AbstractLifecycleDispatcher.Task	allocateTask()
protected void	expandTailRecursionPile(int amount)
int	getBacklog()

Methods inherited from class reactor.event.dispatch.AbstractLifecycleDispatcher

addToTailRecursionPile, 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

AbstractSingleThreadDispatcher

public AbstractSingleThreadDispatcher(int backlog)

Method Detail

getBacklog

public int getBacklog()

expandTailRecursionPile

protected void expandTailRecursionPile(int amount)

allocateRecursiveTask

protected AbstractLifecycleDispatcher.Task allocateRecursiveTask()

Specified by:

allocateRecursiveTask in class AbstractLifecycleDispatcher

allocateTask

protected abstract AbstractLifecycleDispatcher.Task allocateTask()

Specified by:

allocateTask in class AbstractLifecycleDispatcher