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
final class	FixedSequenceGroup	Hides a group of Sequences behind a single Sequence
final class	SequenceGroup	A Sequence group that can dynamically have Sequences added and removed while being thread safe.

Fields in com.lmax.disruptor declared as Sequence

Modifier and Type	Field	Description
protected final Sequence	AbstractSequencer.cursor
protected Sequence[]	AbstractSequencer.gatingSequences

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 the Sequence being used by this EventProcessor.
Sequence	NoOpEventProcessor.getSequence()
Sequence	WorkProcessor.getSequence()
Sequence[]	WorkerPool.getWorkerSequences()	Get an array of Sequences 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 a Sequence 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.
void	SequenceGroup.addWhileRunning(Cursored cursored, Sequence sequence)	Adds a sequence to the sequence group after threads have started to publish to the Disruptor.
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 the Sequence 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.
void	SequenceReportingEventHandler.setSequenceCallback(Sequence sequenceCallback)	Call by the BatchEventProcessor 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

Modifier	Constructor	Description
	EventPoller(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence)
	FixedSequenceGroup(Sequence[] sequences)	Constructor
	WorkProcessor(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, WorkHandler<? super T> workHandler, ExceptionHandler<? super T> exceptionHandler, Sequence workSequence)	Construct a WorkProcessor.

Uses of Sequence in com.lmax.disruptor.dsl

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 on barrierSequences.

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 of Sequences for the passed EventProcessors

Methods 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 of Sequences.
static long	Util.getMinimumSequence(Sequence[] sequences, long minimum)	Get the minimum sequence from an array of Sequences.