Uses of Class
com.lmax.disruptor.Sequence

Packages that use Sequence

com.lmax.disruptor	The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
com.lmax.disruptor.util

Uses of Sequence in com.lmax.disruptor

Subclasses of Sequence in com.lmax.disruptor

class

SequenceGroup Sequence group that can dynamically have Sequences added and removed while being thread safe.

Methods in com.lmax.disruptor that return Sequence

Sequence	EventProcessor.getSequence() Get a reference to the Sequence being used by this EventProcessor.
Sequence	NoOpEventProcessor.getSequence()
Sequence	BatchEventProcessor.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

void	SequenceGroup.add(Sequence sequence) Add a Sequence into this aggregate.
long	AbstractMultithreadedClaimStrategy.checkAndIncrement(int availableCapacity, int delta, Sequence[] gatingSequences)
long	SingleThreadedClaimStrategy.checkAndIncrement(int availableCapacity, int delta, Sequence[] dependentSequences)
long	ClaimStrategy.checkAndIncrement(int availableCapacity, int delta, Sequence[] gatingSequences) Atomically checks the available capacity of the ring buffer and claims the next sequence.
boolean	AbstractMultithreadedClaimStrategy.hasAvailableCapacity(int availableCapacity, Sequence[] dependentSequences)
boolean	SingleThreadedClaimStrategy.hasAvailableCapacity(int availableCapacity, Sequence[] dependentSequences)
boolean	ClaimStrategy.hasAvailableCapacity(int availableCapacity, Sequence[] dependentSequences) Is there available capacity in the buffer for the requested sequence.
long	AbstractMultithreadedClaimStrategy.incrementAndGet(int delta, Sequence[] dependentSequences)
long	SingleThreadedClaimStrategy.incrementAndGet(int delta, Sequence[] dependentSequences)
long	ClaimStrategy.incrementAndGet(int delta, Sequence[] dependentSequences) Increment sequence by a delta and get the result.
long	AbstractMultithreadedClaimStrategy.incrementAndGet(Sequence[] dependentSequences)
long	SingleThreadedClaimStrategy.incrementAndGet(Sequence[] dependentSequences)
long	ClaimStrategy.incrementAndGet(Sequence[] dependentSequences) Claim the next sequence in the Sequencer.
SequenceBarrier	Sequencer.newBarrier(Sequence... sequencesToTrack) Create a SequenceBarrier that gates on the the cursor and a list of Sequences
boolean	SequenceGroup.remove(Sequence sequence) Remove the first occurrence of the Sequence from this aggregate.
void	MultiThreadedLowContentionClaimStrategy.serialisePublishing(long sequence, Sequence cursor, int batchSize)
void	SingleThreadedClaimStrategy.serialisePublishing(long sequence, Sequence cursor, int batchSize)
void	MultiThreadedClaimStrategy.serialisePublishing(long sequence, Sequence cursor, int batchSize)
void	ClaimStrategy.serialisePublishing(long sequence, Sequence cursor, int batchSize) Serialise publishers in sequence and set cursor to latest available sequence.
void	Sequencer.setGatingSequences(Sequence... sequences) Set the sequences that will gate publishers to prevent the buffer wrapping.
void	AbstractMultithreadedClaimStrategy.setSequence(long sequence, Sequence[] dependentSequences)
void	SingleThreadedClaimStrategy.setSequence(long sequence, Sequence[] dependentSequences)
void	ClaimStrategy.setSequence(long sequence, Sequence[] dependentSequences) Set the current sequence value for claiming an event in the Sequencer The caller should be held up until the claimed sequence is available by tracking the dependentSequences.
void	SequenceReportingEventHandler.setSequenceCallback(Sequence sequenceCallback) Call by the BatchEventProcessor to setup the callback.
long	BusySpinWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier)
long	BusySpinWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier)
long	BlockingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier)
long	BlockingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier)
long	YieldingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier)
long	YieldingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier)
long	SleepingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier)
long	SleepingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier)
long	WaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier) Wait for the given sequence to be available
long	WaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier) Wait for the given sequence to be available
long	BusySpinWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit)
long	BusySpinWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit)
long	BlockingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit)
long	BlockingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit)
long	YieldingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit)
long	YieldingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit)
long	SleepingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit)
long	SleepingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit)
long	WaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit) Wait for the given sequence to be available with a timeout specified.
long	WaitStrategy.waitFor(long sequence, Sequence cursor, Sequence[] dependents, SequenceBarrier barrier, long timeout, java.util.concurrent.TimeUnit sourceUnit) Wait for the given sequence to be available with a timeout specified.

Constructors in com.lmax.disruptor with parameters of type Sequence

WorkProcessor(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, WorkHandler<T> workHandler, ExceptionHandler exceptionHandler, Sequence workSequence)
Construct a WorkProcessor.

Uses of Sequence in com.lmax.disruptor.util

Methods in com.lmax.disruptor.util that return Sequence

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

static long

Util.getMinimumSequence(Sequence[] sequences) Get the minimum sequence from an array of Sequences.