Uses of Package
com.lmax.disruptor
-
Packages that use com.lmax.disruptor 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 A DSL-style API for setting up the disruptor pattern around a ring buffer.com.lmax.disruptor.util Utility classes -
Classes in com.lmax.disruptor used by com.lmax.disruptor Class Description AbstractSequencer Base class for the various sequencer types (single/multi).AlertException Used to alertEventProcessor
s waiting at aSequenceBarrier
of status changes.BatchEventProcessor Convenience class for handling the batching semantics of consuming entries from aRingBuffer
and delegating the available events to anEventHandler
.BatchEventProcessorBuilder BatchRewindStrategy Strategy for handling a rewindableException when processing an event.Cursored Implementors of this interface must provide a single long value that represents their current cursor value.DataProvider Typically used to decouple classes fromRingBuffer
to allow easier testingEventFactory Called by theRingBuffer
to pre-populate all the events to fill the RingBuffer.EventHandler Callback interface to be implemented for processing events as they become available in theRingBuffer
EventHandlerIdentity EventPoller Experimental poll-based interface for the Disruptor.EventPoller.Handler A callback used to process eventsEventPoller.PollState Indicates the result of a call toEventPoller.poll(Handler)
EventProcessor An EventProcessor needs to be an implementation of a runnable that will poll for events from theRingBuffer
using the appropriate wait strategy.EventSequencer Pulls together the low-level data access and sequencing operations ofRingBuffer
EventSink Write interface forRingBuffer
.EventTranslator Implementations translate (write) data representations into events claimed from theRingBuffer
.EventTranslatorOneArg Implementations translate another data representations into events claimed from theRingBuffer
EventTranslatorThreeArg Implementations translate another data representations into events claimed from theRingBuffer
EventTranslatorTwoArg Implementations translate another data representations into events claimed from theRingBuffer
EventTranslatorVararg Implementations translate another data representations into events claimed from theRingBuffer
ExceptionHandler Callback handler for uncaught exceptions in the event processing cycle of theBatchEventProcessor
InsufficientCapacityException Exception thrown when it is not possible to insert a value into the ring buffer without it wrapping the consuming sequences.PhasedBackoffWaitStrategy Phased wait strategy for waitingEventProcessor
s on a barrier.RewindableEventHandler Callback interface to be implemented for processing events as they become available in theRingBuffer
with support for throwing aRewindableException
when an even cannot be processed currently but may succeed on retry.RewindableException A special exception that can be thrown while using theBatchEventProcessor
.RewindAction The result returned from theBatchRewindStrategy
that decides whether to rewind or throw the exceptionRingBuffer Ring based store of reusable entries containing the data representing an event being exchanged between event producer andEventProcessor
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 dependentEventProcessor
s for processing a data structureSequenced Operations related to the sequencing of items in aRingBuffer
.Sequencer Coordinates claiming sequences for access to a data structure while tracking dependentSequence
sTimeoutException Wait strategies may throw this Exception to inform callers that a message has not been detected within a specific time window.WaitStrategy Strategy employed for makingEventProcessor
s wait on a cursorSequence
. -
Classes in com.lmax.disruptor used by com.lmax.disruptor.dsl Class Description BatchRewindStrategy Strategy for handling a rewindableException when processing an event.EventFactory Called by theRingBuffer
to pre-populate all the events to fill the RingBuffer.EventHandler Callback interface to be implemented for processing events as they become available in theRingBuffer
EventHandlerIdentity EventProcessor An EventProcessor needs to be an implementation of a runnable that will poll for events from theRingBuffer
using the appropriate wait strategy.EventTranslator Implementations translate (write) data representations into events claimed from theRingBuffer
.EventTranslatorOneArg Implementations translate another data representations into events claimed from theRingBuffer
EventTranslatorThreeArg Implementations translate another data representations into events claimed from theRingBuffer
EventTranslatorTwoArg Implementations translate another data representations into events claimed from theRingBuffer
ExceptionHandler Callback handler for uncaught exceptions in the event processing cycle of theBatchEventProcessor
RewindableEventHandler Callback interface to be implemented for processing events as they become available in theRingBuffer
with support for throwing aRewindableException
when an even cannot be processed currently but may succeed on retry.RingBuffer Ring based store of reusable entries containing the data representing an event being exchanged between event producer andEventProcessor
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 dependentEventProcessor
s for processing a data structureTimeoutException Wait strategies may throw this Exception to inform callers that a message has not been detected within a specific time window.WaitStrategy Strategy employed for makingEventProcessor
s wait on a cursorSequence
. -
Classes in com.lmax.disruptor used by com.lmax.disruptor.util Class Description EventProcessor An EventProcessor needs to be an implementation of a runnable that will poll for events from theRingBuffer
using the appropriate wait strategy.Sequence Concurrent sequence class used for tracking the progress of the ring buffer and event processors.