reactor.event.dispatch

Class WorkQueueDispatcher

java.lang.Object

reactor.event.dispatch.AbstractLifecycleDispatcher

reactor.event.dispatch.AbstractMultiThreadDispatcher

reactor.event.dispatch.WorkQueueDispatcher

All Implemented Interfaces:

java.util.concurrent.Executor, Dispatcher

public class WorkQueueDispatcher
extends AbstractMultiThreadDispatcher

Implementation of a Dispatcher that uses a multi-threaded, multi-producer RingBuffer to queue tasks to execute.

Since:

1.1

Nested Class Summary

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

AbstractMultiThreadDispatcher.MultiThreadTask

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

AbstractLifecycleDispatcher.Task

Constructor Summary

Constructors

Constructor and Description
WorkQueueDispatcher(java.lang.String name, int poolSize, int backlog, Consumer<java.lang.Throwable> uncaughtExceptionHandler)
WorkQueueDispatcher(java.lang.String name, int poolSize, int backlog, Consumer<java.lang.Throwable> uncaughtExceptionHandler, com.lmax.disruptor.dsl.ProducerType producerType, com.lmax.disruptor.WaitStrategy waitStrategy)

Method Summary

Modifier and Type	Method and Description
protected AbstractLifecycleDispatcher.Task	allocateTask()
boolean	awaitAndShutdown(long timeout, java.util.concurrent.TimeUnit timeUnit) Block until all submitted tasks have completed, then do a normal Dispatcher.shutdown().
protected void	execute(AbstractLifecycleDispatcher.Task task)
void	halt() Shutdown this Dispatcher, forcibly halting any tasks currently executing and discarding any tasks that have not yet been exected.
void	shutdown() Shutdown this Dispatcher such that it can no longer be used.

Methods inherited from class reactor.event.dispatch.AbstractMultiThreadDispatcher

addToTailRecursionPile, allocateRecursiveTask, getBacklog

Methods inherited from class reactor.event.dispatch.AbstractLifecycleDispatcher

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

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkQueueDispatcher

public WorkQueueDispatcher(java.lang.String name,
                           int poolSize,
                           int backlog,
                           Consumer<java.lang.Throwable> uncaughtExceptionHandler)

WorkQueueDispatcher

public WorkQueueDispatcher(java.lang.String name,
                           int poolSize,
                           int backlog,
                           Consumer<java.lang.Throwable> uncaughtExceptionHandler,
                           com.lmax.disruptor.dsl.ProducerType producerType,
                           com.lmax.disruptor.WaitStrategy waitStrategy)

Method Detail

awaitAndShutdown

public boolean awaitAndShutdown(long timeout,
                                java.util.concurrent.TimeUnit timeUnit)

Description copied from interface: Dispatcher

Block until all submitted tasks have completed, then do a normal Dispatcher.shutdown().

shutdown

public void shutdown()

Description copied from interface: Dispatcher

Shutdown this Dispatcher such that it can no longer be used.

Specified by:

shutdown in interface Dispatcher

Overrides:

shutdown in class AbstractLifecycleDispatcher

halt

public void halt()

Description copied from interface: Dispatcher

Shutdown this Dispatcher, forcibly halting any tasks currently executing and discarding any tasks that have not yet been exected.

Specified by:

halt in interface Dispatcher

Overrides:

halt in class AbstractLifecycleDispatcher

allocateTask

protected AbstractLifecycleDispatcher.Task allocateTask()

Overrides:

allocateTask in class AbstractMultiThreadDispatcher

execute

protected void execute(AbstractLifecycleDispatcher.Task task)

Specified by:

execute in class AbstractLifecycleDispatcher