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 com.lmax.disruptor.util -
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.Cursored Implementors of this interface must provide a single long value that represents their current cursor value.DataProvider 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
EventPoller Experimental poll-based interface for the Disruptor.EventPoller.Handler EventPoller.PollState EventProcessor EventProcessors waitFor events to become available for consumption from theRingBuffer
EventReleaser EventSequencer EventSink 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.LifecycleAware Implement this interface in yourEventHandler
to be notified when a thread for theBatchEventProcessor
starts and shuts down.PhasedBackoffWaitStrategy Phased wait strategy for waitingEventProcessor
s on a barrier.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 structureSequenced Sequencer Coordinates claiming sequences for access to a data structure while tracking dependentSequence
sTimeoutException WaitStrategy Strategy employed for makingEventProcessor
s wait on a cursorSequence
.WorkHandler Callback interface to be implemented for processing units of work as they become available in theRingBuffer
. -
Classes in com.lmax.disruptor used by com.lmax.disruptor.dsl Class Description 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
EventProcessor EventProcessors waitFor events to become available for consumption from theRingBuffer
EventTranslator Implementations translate (write) data representations into events claimed from theRingBuffer
.EventTranslatorOneArg Implementations translate another data representations into events claimed from theRingBuffer
ExceptionHandler Callback handler for uncaught exceptions in the event processing cycle of theBatchEventProcessor
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 WaitStrategy Strategy employed for makingEventProcessor
s wait on a cursorSequence
.WorkHandler Callback interface to be implemented for processing units of work as they become available in theRingBuffer
. -
Classes in com.lmax.disruptor used by com.lmax.disruptor.util Class Description EventProcessor EventProcessors waitFor events to become available for consumption from theRingBuffer
Sequence Concurrent sequence class used for tracking the progress of the ring buffer and event processors.