Uses of Class
com.lmax.disruptor.Sequence
Packages that use Sequence
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
-
Uses of Sequence in com.lmax.disruptor
Subclasses of Sequence in com.lmax.disruptorModifier and TypeClassDescriptionfinal class
Hides a group of Sequences behind a single Sequenceprivate static final class
Sequence that follows (by wrapping) another sequencefinal class
Fields in com.lmax.disruptor declared as SequenceModifier and TypeFieldDescriptionprotected final Sequence
AbstractSequencer.cursor
private final Sequence
ProcessingSequenceBarrier.cursorSequence
private final Sequence
ProcessingSequenceBarrier.dependentSequence
private final Sequence
EventPoller.gatingSequence
private final Sequence
MultiProducerSequencer.gatingSequenceCache
protected Sequence[]
AbstractSequencer.gatingSequences
private final Sequence
BatchEventProcessor.sequence
private final Sequence
EventPoller.sequence
private final Sequence
WorkProcessor.sequence
private final Sequence[]
FixedSequenceGroup.sequences
private Sequence[]
SequenceGroup.sequences
private final Sequence
WorkerPool.workSequence
private final Sequence
WorkProcessor.workSequence
Methods in com.lmax.disruptor that return SequenceModifier and TypeMethodDescriptionBatchEventProcessor.getSequence()
EventPoller.getSequence()
EventProcessor.getSequence()
Get a reference to theSequence
being used by thisEventProcessor
.NoOpEventProcessor.getSequence()
WorkProcessor.getSequence()
Sequence[]
WorkerPool.getWorkerSequences()
Get an array ofSequence
s representing the progress of the workers.Methods in com.lmax.disruptor with parameters of type SequenceModifier and TypeMethodDescriptionvoid
Add aSequence
into this aggregate.final void
AbstractSequencer.addGatingSequences
(Sequence... gatingSequences) void
RingBuffer.addGatingSequences
(Sequence... gatingSequences) Add the specified gating sequences to this instance of the Disruptor.void
Sequencer.addGatingSequences
(Sequence... gatingSequences) Add the specified gating sequences to this instance of the Disruptor.(package private) static <T> void
SequenceGroups.addSequences
(T holder, AtomicReferenceFieldUpdater<T, Sequence[]> updater, Cursored cursor, Sequence... sequencesToAdd) void
SequenceGroup.addWhileRunning
(Cursored cursored, Sequence sequence) Adds a sequence to the sequence group after threads have started to publish to the Disruptor.private boolean
MultiProducerSequencer.hasAvailableCapacity
(Sequence[] gatingSequences, int requiredCapacity, long cursorValue) AbstractSequencer.newBarrier
(Sequence... sequencesToTrack) RingBuffer.newBarrier
(Sequence... sequencesToTrack) Create a new SequenceBarrier to be used by an EventProcessor to track which messages are available to be read from the ring buffer given a list of sequences to track.Sequencer.newBarrier
(Sequence... sequencesToTrack) Create a new SequenceBarrier to be used by an EventProcessor to track which messages are available to be read from the ring buffer given a list of sequences to track.static <T> EventPoller
<T> EventPoller.newInstance
(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence cursorSequence, Sequence... gatingSequences) <T> EventPoller
<T> AbstractSequencer.newPoller
(DataProvider<T> dataProvider, Sequence... gatingSequences) Creates an event poller for this sequence that will use the supplied data provider and gating sequences.Creates an event poller for this ring buffer gated on the supplied sequences.<T> EventPoller
<T> Sequencer.newPoller
(DataProvider<T> provider, Sequence... gatingSequences) boolean
Remove the first occurrence of theSequence
from this aggregate.boolean
AbstractSequencer.removeGatingSequence
(Sequence sequence) boolean
RingBuffer.removeGatingSequence
(Sequence sequence) Remove the specified sequence from this ringBuffer.boolean
Sequencer.removeGatingSequence
(Sequence sequence) Remove the specified sequence from this sequencer.(package private) static <T> boolean
SequenceGroups.removeSequence
(T holder, AtomicReferenceFieldUpdater<T, Sequence[]> sequenceUpdater, Sequence sequence) void
SequenceReportingEventHandler.setSequenceCallback
(Sequence sequenceCallback) Call by theBatchEventProcessor
to setup the callback.long
BlockingWaitStrategy.waitFor
(long sequence, Sequence cursorSequence, Sequence dependentSequence, SequenceBarrier barrier) long
BusySpinWaitStrategy.waitFor
(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) long
LiteBlockingWaitStrategy.waitFor
(long sequence, Sequence cursorSequence, Sequence dependentSequence, SequenceBarrier barrier) long
LiteTimeoutBlockingWaitStrategy.waitFor
(long sequence, Sequence cursorSequence, Sequence dependentSequence, SequenceBarrier barrier) long
PhasedBackoffWaitStrategy.waitFor
(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) long
SleepingWaitStrategy.waitFor
(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) long
TimeoutBlockingWaitStrategy.waitFor
(long sequence, Sequence cursorSequence, Sequence dependentSequence, SequenceBarrier barrier) long
WaitStrategy.waitFor
(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) Wait for the given sequence to be available.long
YieldingWaitStrategy.waitFor
(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) Constructors in com.lmax.disruptor with parameters of type SequenceModifierConstructorDescriptionEventPoller
(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence) FixedSequenceGroup
(Sequence[] sequences) Constructor(package private)
ProcessingSequenceBarrier
(Sequencer sequencer, WaitStrategy waitStrategy, Sequence cursorSequence, Sequence[] dependentSequences) WorkProcessor
(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, WorkHandler<? super T> workHandler, ExceptionHandler<? super T> exceptionHandler, Sequence workSequence) Construct aWorkProcessor
. -
Uses of Sequence in com.lmax.disruptor.dsl
Fields in com.lmax.disruptor.dsl declared as SequenceFields in com.lmax.disruptor.dsl with type parameters of type SequenceModifier and TypeFieldDescriptionprivate final Map
<Sequence, ConsumerInfo> ConsumerRepository.eventProcessorInfoBySequence
Methods in com.lmax.disruptor.dsl that return SequenceModifier and TypeMethodDescriptionSequence[]
ConsumerRepository.getLastSequenceInChain
(boolean includeStopped) ConsumerRepository.getSequenceFor
(EventHandler<T> handler) Sequence[]
ConsumerInfo.getSequences()
Sequence[]
EventProcessorInfo.getSequences()
Sequence[]
WorkerPoolInfo.getSequences()
Methods in com.lmax.disruptor.dsl with parameters of type SequenceModifier and TypeMethodDescriptionEventProcessorFactory.createEventProcessor
(RingBuffer<T> ringBuffer, Sequence[] barrierSequences) Create a new event processor that gates onbarrierSequences
.(package private) EventHandlerGroup
<T> Disruptor.createEventProcessors
(Sequence[] barrierSequences, EventProcessorFactory<T>[] processorFactories) (package private) EventHandlerGroup
<T> Disruptor.createEventProcessors
(Sequence[] barrierSequences, EventHandler<? super T>[] eventHandlers) (package private) EventHandlerGroup
<T> Disruptor.createWorkerPool
(Sequence[] barrierSequences, WorkHandler<? super T>[] workHandlers) private ConsumerInfo
ConsumerRepository.getEventProcessorInfo
(Sequence barrierEventProcessor) void
ConsumerRepository.unMarkEventProcessorsAsEndOfChain
(Sequence... barrierEventProcessors) private void
Disruptor.updateGatingSequencesForNextInChain
(Sequence[] barrierSequences, Sequence[] processorSequences) Constructors in com.lmax.disruptor.dsl with parameters of type SequenceModifierConstructorDescription(package private)
EventHandlerGroup
(Disruptor<T> disruptor, ConsumerRepository<T> consumerRepository, Sequence[] sequences) -
Uses of Sequence in com.lmax.disruptor.util
Methods in com.lmax.disruptor.util that return SequenceModifier and TypeMethodDescriptionstatic Sequence[]
Util.getSequencesFor
(EventProcessor... processors) Get an array ofSequence
s for the passedEventProcessor
sMethods in com.lmax.disruptor.util with parameters of type SequenceModifier and TypeMethodDescriptionstatic long
Util.getMinimumSequence
(Sequence[] sequences) Get the minimum sequence from an array ofSequence
s.static long
Util.getMinimumSequence
(Sequence[] sequences, long minimum) Get the minimum sequence from an array ofSequence
s.