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 classHides a group of Sequences behind a single Sequenceprivate static final classSequence that follows (by wrapping) another sequencefinal classFields in com.lmax.disruptor declared as SequenceModifier and TypeFieldDescriptionprotected final SequenceAbstractSequencer.cursorprivate final SequenceProcessingSequenceBarrier.cursorSequenceprivate final SequenceProcessingSequenceBarrier.dependentSequenceprivate final SequenceEventPoller.gatingSequenceprivate final SequenceMultiProducerSequencer.gatingSequenceCacheprotected Sequence[]AbstractSequencer.gatingSequencesprivate final SequenceBatchEventProcessor.sequenceprivate final SequenceEventPoller.sequenceprivate final SequenceWorkProcessor.sequenceprivate final Sequence[]FixedSequenceGroup.sequencesprivate Sequence[]SequenceGroup.sequencesprivate final SequenceWorkerPool.workSequenceprivate final SequenceWorkProcessor.workSequenceMethods in com.lmax.disruptor that return SequenceModifier and TypeMethodDescriptionBatchEventProcessor.getSequence()EventPoller.getSequence()EventProcessor.getSequence()Get a reference to theSequencebeing used by thisEventProcessor.NoOpEventProcessor.getSequence()WorkProcessor.getSequence()Sequence[]WorkerPool.getWorkerSequences()Get an array ofSequences representing the progress of the workers.Methods in com.lmax.disruptor with parameters of type SequenceModifier and TypeMethodDescriptionvoidAdd aSequenceinto this aggregate.final voidAbstractSequencer.addGatingSequences(Sequence... gatingSequences) voidRingBuffer.addGatingSequences(Sequence... gatingSequences) Add the specified gating sequences to this instance of the Disruptor.voidSequencer.addGatingSequences(Sequence... gatingSequences) Add the specified gating sequences to this instance of the Disruptor.(package private) static <T> voidSequenceGroups.addSequences(T holder, AtomicReferenceFieldUpdater<T, Sequence[]> updater, Cursored cursor, Sequence... sequencesToAdd) voidSequenceGroup.addWhileRunning(Cursored cursored, Sequence sequence) Adds a sequence to the sequence group after threads have started to publish to the Disruptor.private booleanMultiProducerSequencer.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) booleanRemove the first occurrence of theSequencefrom this aggregate.booleanAbstractSequencer.removeGatingSequence(Sequence sequence) booleanRingBuffer.removeGatingSequence(Sequence sequence) Remove the specified sequence from this ringBuffer.booleanSequencer.removeGatingSequence(Sequence sequence) Remove the specified sequence from this sequencer.(package private) static <T> booleanSequenceGroups.removeSequence(T holder, AtomicReferenceFieldUpdater<T, Sequence[]> sequenceUpdater, Sequence sequence) voidSequenceReportingEventHandler.setSequenceCallback(Sequence sequenceCallback) Call by theBatchEventProcessorto setup the callback.longBlockingWaitStrategy.waitFor(long sequence, Sequence cursorSequence, Sequence dependentSequence, SequenceBarrier barrier) longBusySpinWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) longLiteBlockingWaitStrategy.waitFor(long sequence, Sequence cursorSequence, Sequence dependentSequence, SequenceBarrier barrier) longLiteTimeoutBlockingWaitStrategy.waitFor(long sequence, Sequence cursorSequence, Sequence dependentSequence, SequenceBarrier barrier) longPhasedBackoffWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) longSleepingWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) longTimeoutBlockingWaitStrategy.waitFor(long sequence, Sequence cursorSequence, Sequence dependentSequence, SequenceBarrier barrier) longWaitStrategy.waitFor(long sequence, Sequence cursor, Sequence dependentSequence, SequenceBarrier barrier) Wait for the given sequence to be available.longYieldingWaitStrategy.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.eventProcessorInfoBySequenceMethods 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 ConsumerInfoConsumerRepository.getEventProcessorInfo(Sequence barrierEventProcessor) voidConsumerRepository.unMarkEventProcessorsAsEndOfChain(Sequence... barrierEventProcessors) private voidDisruptor.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 ofSequences for the passedEventProcessorsMethods in com.lmax.disruptor.util with parameters of type SequenceModifier and TypeMethodDescriptionstatic longUtil.getMinimumSequence(Sequence[] sequences) Get the minimum sequence from an array ofSequences.static longUtil.getMinimumSequence(Sequence[] sequences, long minimum) Get the minimum sequence from an array ofSequences.