rsb.eventprocessing

Class UnorderedParallelEventReceivingStrategy

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

rsb.eventprocessing.UnorderedParallelEventReceivingStrategy

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService, EventReceivingStrategy, EventHandler

public class UnorderedParallelEventReceivingStrategy
extends java.util.concurrent.ThreadPoolExecutor
implements EventReceivingStrategy

An EventReceivingStrategy that dispatches Events using a thread pool but without any ordering guarantees.

Author:

swrede

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor and Description
UnorderedParallelEventReceivingStrategy()
UnorderedParallelEventReceivingStrategy(int coreThreads, int maxThreads, int maxQueue)

Method Summary

Methods

Modifier and Type	Method and Description
void	addFilter(Filter filter) Adds a filter that is applied for all registered handlers some time after this method call.
void	addHandler(Handler handler, boolean wait)
void	handle(Event event)
void	removeFilter(Filter filter) Removes a filter that is remove for all registered handlers some time after this method call.
void	removeHandler(Handler handler, boolean wait)
void	shutdownAndWait()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

afterExecute, allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, terminated, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Constructor Detail

UnorderedParallelEventReceivingStrategy

public UnorderedParallelEventReceivingStrategy()

UnorderedParallelEventReceivingStrategy

public UnorderedParallelEventReceivingStrategy(int coreThreads,
                                       int maxThreads,
                                       int maxQueue)

Method Detail

addFilter

public void addFilter(Filter filter)

Description copied from interface: EventReceivingStrategy

Adds a filter that is applied for all registered handlers some time after this method call.

Specified by:

addFilter in interface EventReceivingStrategy

Parameters:

filter - filter to add, not null

removeFilter

public void removeFilter(Filter filter)

Description copied from interface: EventReceivingStrategy

Removes a filter that is remove for all registered handlers some time after this method call.

Specified by:

removeFilter in interface EventReceivingStrategy

Parameters:

filter - filter to remove, not null

addHandler

public void addHandler(Handler handler,
              boolean wait)

Specified by:

addHandler in interface EventReceivingStrategy

removeHandler

public void removeHandler(Handler handler,
                 boolean wait)
                   throws java.lang.InterruptedException

Specified by:

removeHandler in interface EventReceivingStrategy

Throws:

java.lang.InterruptedException

handle

public void handle(Event event)

Specified by:

handle in interface EventHandler

shutdownAndWait

public void shutdownAndWait()
                     throws java.lang.InterruptedException

Specified by:

shutdownAndWait in interface EventReceivingStrategy

Throws:

java.lang.InterruptedException - thrown if waiting for shutdown was interrupted.