Uses of Class
com.lmax.disruptor.Sequence
-
Packages that use Sequence 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 -
-
Uses of Sequence in com.lmax.disruptor
Subclasses of Sequence in com.lmax.disruptor Modifier and Type Class Description class
FixedSequenceGroup
Hides a group of Sequences behind a single Sequenceprivate static class
NoOpEventProcessor.SequencerFollowingSequence
Sequence that follows (by wrapping) another sequenceclass
SequenceGroup
Fields in com.lmax.disruptor declared as Sequence Modifier and Type Field Description protected Sequence
AbstractSequencer. cursor
private Sequence
ProcessingSequenceBarrier. cursorSequence
private Sequence
ProcessingSequenceBarrier. dependentSequence
private Sequence
EventPoller. gatingSequence
private Sequence
MultiProducerSequencer. gatingSequenceCache
protected Sequence[]
AbstractSequencer. gatingSequences
private Sequence
BatchEventProcessor. sequence
private Sequence
EventPoller. sequence
private Sequence
WorkProcessor. sequence
private Sequence[]
FixedSequenceGroup. sequences
private Sequence[]
SequenceGroup. sequences
private Sequence
WorkerPool. workSequence
private Sequence
WorkProcessor. workSequence
Methods in com.lmax.disruptor that return Sequence Modifier and Type Method Description Sequence
BatchEventProcessor. getSequence()
Sequence
EventPoller. getSequence()
Sequence
EventProcessor. getSequence()
Get a reference to theSequence
being used by thisEventProcessor
.Sequence
NoOpEventProcessor. getSequence()
Sequence
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 Sequence Modifier and Type Method Description void
SequenceGroup. add(Sequence sequence)
Add aSequence
into this aggregate.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, java.util.concurrent.atomic.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)
SequenceBarrier
AbstractSequencer. newBarrier(Sequence... sequencesToTrack)
SequenceBarrier
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.SequenceBarrier
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.EventPoller<E>
RingBuffer. newPoller(Sequence... gatingSequences)
Creates an event poller for this ring buffer gated on the supplied sequences.<T> EventPoller<T>
Sequencer. newPoller(DataProvider<T> provider, Sequence... gatingSequences)
boolean
SequenceGroup. remove(Sequence sequence)
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, java.util.concurrent.atomic.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 Sequence Constructor Description EventPoller(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence)
FixedSequenceGroup(Sequence[] sequences)
ConstructorProcessingSequenceBarrier(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 Sequence Modifier and Type Field Description private Sequence[]
EventHandlerGroup. sequences
Fields in com.lmax.disruptor.dsl with type parameters of type Sequence Modifier and Type Field Description private java.util.Map<Sequence,ConsumerInfo>
ConsumerRepository. eventProcessorInfoBySequence
Methods in com.lmax.disruptor.dsl that return Sequence Modifier and Type Method Description Sequence[]
ConsumerRepository. getLastSequenceInChain(boolean includeStopped)
Sequence
ConsumerRepository. getSequenceFor(EventHandler<T> handler)
Sequence[]
ConsumerInfo. getSequences()
Sequence[]
EventProcessorInfo. getSequences()
Sequence[]
WorkerPoolInfo. getSequences()
Methods in com.lmax.disruptor.dsl with parameters of type Sequence Modifier and Type Method Description EventProcessor
EventProcessorFactory. 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 Sequence Constructor Description 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 Sequence Modifier and Type Method Description static Sequence[]
Util. getSequencesFor(EventProcessor... processors)
Get an array ofSequence
s for the passedEventProcessor
sMethods in com.lmax.disruptor.util with parameters of type Sequence Modifier and Type Method Description static 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.
-