reactor.event.dispatch

Class ThreadPoolExecutorDispatcher

java.lang.Object

reactor.event.dispatch.AbstractLifecycleDispatcher

reactor.event.dispatch.AbstractMultiThreadDispatcher

reactor.event.dispatch.ThreadPoolExecutorDispatcher

All Implemented Interfaces:

java.util.concurrent.Executor, Dispatcher

public class ThreadPoolExecutorDispatcher
extends AbstractMultiThreadDispatcher

A Dispatcher that uses a ThreadPoolExecutor with an unbounded queue to dispatch events.

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
ThreadPoolExecutorDispatcher(int poolSize, int backlog) Creates a new ThreadPoolExecutorDispatcher with the given poolSize and backlog.
ThreadPoolExecutorDispatcher(int backlog, int poolSize, java.util.concurrent.ExecutorService executor) Create a new ThreadPoolTaskExecutor with the given backlog and ExecutorService.
ThreadPoolExecutorDispatcher(int poolSize, int backlog, java.lang.String threadName) Create a new ThreadPoolExecutorDispatcher with the given size, backlog, name, and RejectedExecutionHandler.
ThreadPoolExecutorDispatcher(int poolSize, int backlog, java.lang.String threadName, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler) Create a new ThreadPoolExecutorDispatcher with the given size, backlog, name, and RejectedExecutionHandler.

Method Summary

Modifier and Type	Method and Description
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	execute(java.lang.Runnable command)
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, allocateTask, getBacklog

Methods inherited from class reactor.event.dispatch.AbstractLifecycleDispatcher

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

Methods inherited from class java.lang.Object

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

Constructor Detail

ThreadPoolExecutorDispatcher

public ThreadPoolExecutorDispatcher(int poolSize,
                                    int backlog)

Creates a new ThreadPoolExecutorDispatcher with the given poolSize and backlog. By default, a RejectedExecutionHandler is created which runs the submitted Runnable in the calling thread. To change this behavior, specify your own.

Parameters:

poolSize - the pool size

backlog - the backlog size

ThreadPoolExecutorDispatcher

public ThreadPoolExecutorDispatcher(int poolSize,
                                    int backlog,
                                    java.lang.String threadName)

Create a new ThreadPoolExecutorDispatcher with the given size, backlog, name, and RejectedExecutionHandler.

Parameters:

poolSize - the pool size

backlog - the backlog size

threadName - the name prefix to use when creating threads

ThreadPoolExecutorDispatcher

public ThreadPoolExecutorDispatcher(int poolSize,
                                    int backlog,
                                    java.lang.String threadName,
                                    java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                    java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)

Create a new ThreadPoolExecutorDispatcher with the given size, backlog, name, and RejectedExecutionHandler.

Parameters:

poolSize - the pool size

backlog - the backlog size

threadName - the name prefix to use when creating threads

rejectedExecutionHandler - the RejectedExecutionHandler to use when jobs can't be submitted to the thread pool

ThreadPoolExecutorDispatcher

public ThreadPoolExecutorDispatcher(int backlog,
                                    int poolSize,
                                    java.util.concurrent.ExecutorService executor)

Create a new ThreadPoolTaskExecutor with the given backlog and ExecutorService.

Parameters:

backlog - the task backlog

poolSize - the number of threads

executor - the executor to use to execute tasks

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

execute

protected void execute(AbstractLifecycleDispatcher.Task task)

Specified by:

execute in class AbstractLifecycleDispatcher

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

Overrides:

execute in class AbstractLifecycleDispatcher