All Classes

Class Summary
AbstractEventHandler	Created by IntelliJ IDEA.
AbstractPipe	Provides the base functionality for the other `Pipe` types.
AbstractThreadPolicy	The AbstractThreadPolicy keeps track of wether the management thread is running or not, and stores the ThreadManager for future use.
Command	A Command is a specific type of event that denotes an asynchronous execution unit that must be performed by the DefaultCommandManager.
CommandEventHandler	The CommandEventHandler is used by the DefaultCommandManager to actually process the events.
CommandEventPipeline	Created by IntelliJ IDEA.
CommandFailureHandler	CommandFailureHandler is used by the DefaultCommandManager to handle any exceptions that might be thrown by a Command.
CommandManager	Created by IntelliJ IDEA.
DefaultCommandFailureHandler	DefaultCommandFailureHandler is used to do nothing if a command fails.
DefaultCommandManager	The DefaultCommandManager handles asynchronous commands from the rest of the system.
DefaultCommandManager.DelayedCommandInfo	This class encapsulates the information needed to keep track of our progress executing delayed and repeated commands.
DefaultPipe	The default queue implementation is a variable size queue.
DefaultPipe.DefaultPreparedEnqueue
DefaultThreadManager	The DefaultThreadManager is a very flexible implementation that should be able to solve just about any need.
DelayedCommand	A DelayedCommand is a specific type of Command that denotes a an execution unit that will be delayed at least X number of milliseconds.
DequeueInterceptor	The dequeue executable interface describes operations that are executed before and after elements are pulled from a queue.
EnqueuePredicate	Enqueue predicates allow users to specify a method that will 'screen' elements being enqueued onto a sink, either accepting or rejecting them.
EnqueuePredicateFailedException	If the EnqueuePredicate returns false, denying an event to the Sink, the Sink will throw this exception.
EventHandler	An `EventHandler` takes care of processing specific events in an event-based architecture.
EventPipeline	An EventPipeline is used by the ThreadManager to manage the event Pipe and EventHandler relationship.
EventPipelineRunner	Created by IntelliJ IDEA.
GroupedThreadFactory	The GroupedThreadFactory is a convenience implementation for the concurrent utilitie's ThreadFactory.
MultiCastSink	This is a Sink implementation that multicasts enqueue operations to the contained and concrete sink objects.
MultiCastSink.MultiCastPreparedEnqueue	A prepared enqueue object that holds other prepared enqueue objects and allows to perform a commit / abort on all of these objects.
NullCommandFailureHandler	DefaultCommandFailureHandler is used to do nothing if a command fails.
NullDequeueInterceptor	The dequeue executable interface describes operations that are executed before and after elements are pulled from a queue.
NullEnqueuePredicate	The NullEnqueuePredicate does nothing to limit a Pipe's ability to enqueue.
OneThreadPolicy	Created by IntelliJ IDEA.
Pipe	A Source implements the side of an event queue where QueueElements are dequeued operations only.
PreparedEnqueue	A `PreparedEnqueue` is an object returned from a `prepareEnqueue` method that allows you to either commit or abort the enqueue operation.
ProcessorBoundThreadPolicy	The ProcessorBoundThreadPolicy is a ThreadPolicy designed to process pipelines in a number of threads that is a multiple of the number of threads in the system.
RateLimitingPredicate	This enqueue predicate implements input rate policing.
RepeatedCommand	The RepeatedCommand is used to represent a command that operates at a specified interval over time.
Sink	A Sink implements the end of a finite-length event queue where elements are enqueued.
SinkClosedException	A SinkClosedException is thrown when an enqueue operation occurs on a queue that is already closed.
SinkException	A SourceException is thrown when an enqueue operation fails.
SinkFullException	A SinkException is thrown when an enqueue operation occurs on a queue that is already full.
Source	A Source implements the side of an event queue where QueueElements are dequeued operations only.
SwitchedEnqueuePredicate	The SwitchedEnqueuePredicate provides a mechanism where we can explicitly tell the queue whether we are accepting new events or not.
ThreadManager	A ThreadManager handles the thread policies for EventPipelines.
ThreadPolicy	The ThreadPolicy is used to control how the EventPipelineRunner is set up, and how new threads are created and destroyed over the life of the system.
ThresholdEnqueuePredicate	The ThresholdEnqueuePredicate limits the elements that can be enqueued based on the size of the Pipe.