Package | Description |
---|---|
com.lmax.disruptor |
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
|
com.lmax.disruptor.dsl | |
com.lmax.disruptor.util |
Class and Description |
---|
AbstractSequencer
Base class for the various sequencer types (single/multi).
|
AlertException
Used to alert
EventProcessor s waiting at a SequenceBarrier of status changes. |
Cursored
Implementors of this interface must provide a single long value
that represents their current cursor value.
|
DataProvider |
EventFactory
Called by the
RingBuffer to pre-populate all the events to fill the RingBuffer. |
EventHandler
Callback interface to be implemented for processing events as they become available in the
RingBuffer |
EventPoller
Experimental poll-based interface for the Disruptor.
|
EventPoller.Handler |
EventPoller.PollState |
EventProcessor
EventProcessors waitFor events to become available for consumption from the
RingBuffer |
EventReleaser |
EventSequencer |
EventSink |
EventTranslator
Implementations translate (write) data representations into events claimed from the
RingBuffer . |
EventTranslatorOneArg
Implementations translate another data representations into events claimed from the
RingBuffer |
EventTranslatorThreeArg
Implementations translate another data representations into events claimed from the
RingBuffer |
EventTranslatorTwoArg
Implementations translate another data representations into events claimed from the
RingBuffer |
EventTranslatorVararg
Implementations translate another data representations into events claimed from the
RingBuffer |
ExceptionHandler
Callback handler for uncaught exceptions in the event processing cycle of the
BatchEventProcessor |
InsufficientCapacityException
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 your
EventHandler to be notified when a thread for the
BatchEventProcessor starts and shuts down. |
NoOpEventProcessor.SequencerFollowingSequence
Sequence that follows (by wrapping) another sequence
|
PhasedBackoffWaitStrategy
Phased wait strategy for waiting
EventProcessor s on a barrier. |
RhsPadding |
RingBuffer
Ring based store of reusable entries containing the data representing
an event being exchanged between event producer and
EventProcessor s. |
RingBufferFields |
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
dependent
EventProcessor s for processing a data structure |
Sequenced |
SequenceGroup |
Sequencer
Coordinates claiming sequences for access to a data structure while tracking dependent
Sequence s |
SingleProducerSequencerFields |
SingleProducerSequencerPad |
TimeoutException |
TimeoutHandler |
Value |
WaitStrategy
Strategy employed for making
EventProcessor s wait on a cursor Sequence . |
WorkHandler
Callback interface to be implemented for processing units of work as they become available in the
RingBuffer . |
WorkProcessor
A
WorkProcessor wraps a single WorkHandler , effectively consuming the sequence
and ensuring appropriate barriers. |
Class and Description |
---|
EventFactory
Called by the
RingBuffer to pre-populate all the events to fill the RingBuffer. |
EventHandler
Callback interface to be implemented for processing events as they become available in the
RingBuffer |
EventProcessor
EventProcessors waitFor events to become available for consumption from the
RingBuffer |
EventTranslator
Implementations translate (write) data representations into events claimed from the
RingBuffer . |
EventTranslatorOneArg
Implementations translate another data representations into events claimed from the
RingBuffer |
ExceptionHandler
Callback handler for uncaught exceptions in the event processing cycle of the
BatchEventProcessor |
RingBuffer
Ring based store of reusable entries containing the data representing
an event being exchanged between event producer and
EventProcessor s. |
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
dependent
EventProcessor s for processing a data structure |
TimeoutException |
WaitStrategy
Strategy employed for making
EventProcessor s wait on a cursor Sequence . |
WorkerPool
WorkerPool contains a pool of
WorkProcessor s that will consume sequences so jobs can be farmed out across a pool of workers. |
WorkHandler
Callback interface to be implemented for processing units of work as they become available in the
RingBuffer . |
Class and Description |
---|
EventProcessor
EventProcessors waitFor events to become available for consumption from the
RingBuffer |
Sequence
Concurrent sequence class used for tracking the progress of
the ring buffer and event processors.
|