All Classes
-
All Classes Interface Summary Class Summary Enum Summary Exception Summary Class Description AbstractSequencer Base class for the various sequencer types (single/multi).AggregateEventHandler<T> An aggregate collection ofEventHandler
s that get called in sequence for each event.AlertException Used to alertEventProcessor
s waiting at aSequenceBarrier
of status changes.BasicExecutor BatchEventProcessor<T> Convenience class for handling the batching semantics of consuming entries from aRingBuffer
and delegating the available events to anEventHandler
.BatchStartAware BlockingWaitStrategy Blocking strategy that uses a lock and condition variable forEventProcessor
s waiting on a barrier.BusySpinWaitStrategy Busy Spin strategy that uses a busy spin loop forEventProcessor
s waiting on a barrier.ConsumerInfo ConsumerRepository<T> Provides a repository mechanism to associateEventHandler
s withEventProcessor
sCursored Implementors of this interface must provide a single long value that represents their current cursor value.DaemonThreadFactory Access to a ThreadFactory instance.DataProvider<T> Disruptor<T> A DSL-style API for setting up the disruptor pattern around a ring buffer (aka the Builder pattern).EventFactory<T> Called by theRingBuffer
to pre-populate all the events to fill the RingBuffer.EventHandler<T> Callback interface to be implemented for processing events as they become available in theRingBuffer
EventHandlerGroup<T> A group ofEventProcessor
s used as part of theDisruptor
.EventPoller<T> Experimental poll-based interface for the Disruptor.EventPoller.Handler<T> EventPoller.PollState EventProcessor An EventProcessor needs to be an implementation of a runnable that will poll for events from theRingBuffer
using the appropriate wait strategy.EventProcessorFactory<T> A factory interface to make it possible to include custom event processors in a chain:EventProcessorInfo<T> Wrapper class to tie together a particular event processing stageEventReleaseAware EventReleaser EventSequencer<T> EventSink<E> EventTranslator<T> Implementations translate (write) data representations into events claimed from theRingBuffer
.EventTranslatorOneArg<T,A> Implementations translate another data representations into events claimed from theRingBuffer
EventTranslatorThreeArg<T,A,B,C> Implementations translate another data representations into events claimed from theRingBuffer
EventTranslatorTwoArg<T,A,B> Implementations translate another data representations into events claimed from theRingBuffer
EventTranslatorVararg<T> Implementations translate another data representations into events claimed from theRingBuffer
ExceptionHandler<T> Callback handler for uncaught exceptions in the event processing cycle of theBatchEventProcessor
ExceptionHandlers Provides static methods for accessing a defaultExceptionHandler
object.ExceptionHandlers.DefaultExceptionHandlerHolder ExceptionHandlerSetting<T> A support class used as part of setting an exception handler for a specific event handler.ExceptionHandlerWrapper<T> FatalExceptionHandler Convenience implementation of an exception handler that using standard JDK logging to log the exception asLevel
.SEVERE and re-throw it wrapped in aRuntimeException
FixedSequenceGroup Hides a group of Sequences behind a single SequenceIgnoreExceptionHandler Convenience implementation of an exception handler that using standard JDK logging to log the exception asLevel
.INFOInsufficientCapacityException Exception thrown when it is not possible to insert a value into the ring buffer without it wrapping the consuming sequences.LhsPadding LifecycleAware Implement this interface in yourEventHandler
to be notified when a thread for theBatchEventProcessor
starts and shuts down.LiteBlockingWaitStrategy Variation of theBlockingWaitStrategy
that attempts to elide conditional wake-ups when the lock is uncontended.LiteTimeoutBlockingWaitStrategy Variation of theTimeoutBlockingWaitStrategy
that attempts to elide conditional wake-ups when the lock is uncontended.MultiProducerSequencer Coordinator for claiming sequences for access to a data structure while tracking dependentSequence
s.NoOpEventProcessor No operation version of aEventProcessor
that simply tracks aSequence
.NoOpEventProcessor.SequencerFollowingSequence Sequence that follows (by wrapping) another sequencePhasedBackoffWaitStrategy Phased wait strategy for waitingEventProcessor
s on a barrier.ProcessingSequenceBarrier SequenceBarrier
handed out for gatingEventProcessor
s on a cursor sequence and optional dependentEventProcessor
(s), using the given WaitStrategy.ProducerType Defines producer types to support creation of RingBuffer with correct sequencer and publisher.RhsPadding RingBuffer<E> Ring based store of reusable entries containing the data representing an event being exchanged between event producer andEventProcessor
s.RingBufferFields<E> RingBufferPad Sequence Concurrent sequence class used for tracking the progress of the ring buffer and event processors.SequenceBarrier Coordination barrier for tracking the cursor for publishers and sequence of dependentEventProcessor
s for processing a data structureSequenced SequenceGroup SequenceGroups Provides static methods for managing aSequenceGroup
object.Sequencer Coordinates claiming sequences for access to a data structure while tracking dependentSequence
sSequenceReportingEventHandler<T> Used by theBatchEventProcessor
to set a callback allowing theEventHandler
to notify when it has finished consuming an event if this happens after theEventHandler.onEvent(Object, long, boolean)
call.SingleProducerSequencer Coordinator for claiming sequences for access to a data structure while tracking dependentSequence
s.SingleProducerSequencerFields SingleProducerSequencerPad SleepingWaitStrategy Sleeping strategy that initially spins, then uses a Thread.yield(), and eventually sleep (LockSupport.parkNanos(n)
) for the minimum number of nanos the OS and JVM will allow while theEventProcessor
s are waiting on a barrier.ThreadHints This class captures possible hints that may be used by some runtimes to improve code performance.TimeoutBlockingWaitStrategy TimeoutException TimeoutHandler Util Set of common functions used by the DisruptorValue WaitStrategy Strategy employed for makingEventProcessor
s wait on a cursorSequence
.WorkerPool<T> WorkerPool contains a pool ofWorkProcessor
s that will consume sequences so jobs can be farmed out across a pool of workers.WorkerPoolInfo<T> WorkHandler<T> Callback interface to be implemented for processing units of work as they become available in theRingBuffer
.WorkProcessor<T> AWorkProcessor
wraps a singleWorkHandler
, effectively consuming the sequence and ensuring appropriate barriers.YieldingWaitStrategy Yielding strategy that uses a Thread.yield() forEventProcessor
s waiting on a barrier after an initially spinning.