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 | 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.
|
LifecycleAware |
Implement this interface in your
EventHandler to be notified when a thread for the
BatchEventProcessor starts and shuts down. |
PhasedBackoffWaitStrategy |
Phased wait strategy for waiting
EventProcessor s on a barrier. |
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 |
Sequenced | |
Sequencer |
Coordinates claiming sequences for access to a data structure while tracking dependent
Sequence s |
TimeoutException | |
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 . |
Class | 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 . |
WorkHandler |
Callback interface to be implemented for processing units of work as they become available in the
RingBuffer . |
Class | 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.
|
Copyright © 2019. All rights reserved.