Package | Description |
---|---|
com.lmax.disruptor |
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractSequencer
Base class for the various sequencer types (single/multi).
|
class |
MultiProducerSequencer
Coordinator for claiming sequences for access to a data structure while tracking dependent
Sequence s. |
class |
SingleProducerSequencer
Coordinator for claiming sequences for access to a data structure while tracking dependent
Sequence s. |
(package private) class |
SingleProducerSequencerFields |
(package private) class |
SingleProducerSequencerPad |
Modifier and Type | Field and Description |
---|---|
private Sequencer |
ProcessingSequenceBarrier.sequencer |
protected Sequencer |
RingBufferFields.sequencer |
private Sequencer |
EventPoller.sequencer |
Modifier and Type | Method and Description |
---|---|
static <T> EventPoller<T> |
EventPoller.newInstance(DataProvider<T> dataProvider,
Sequencer sequencer,
Sequence sequence,
Sequence cursorSequence,
Sequence... gatingSequences) |
Constructor and Description |
---|
EventPoller(DataProvider<T> dataProvider,
Sequencer sequencer,
Sequence sequence,
Sequence gatingSequence) |
ProcessingSequenceBarrier(Sequencer sequencer,
WaitStrategy waitStrategy,
Sequence cursorSequence,
Sequence[] dependentSequences) |
RingBuffer(EventFactory<E> eventFactory,
Sequencer sequencer)
Construct a RingBuffer with the full option set.
|
RingBufferFields(EventFactory<E> eventFactory,
Sequencer sequencer) |