Uses of Interface
com.lmax.disruptor.SequenceBarrier
Packages that use SequenceBarrier
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
A DSL-style API for setting up the disruptor pattern around a ring buffer.
-
Uses of SequenceBarrier in com.lmax.disruptor
Classes in com.lmax.disruptor that implement SequenceBarrierModifier and TypeClassDescription(package private) final classSequenceBarrierhanded out for gatingEventProcessors on a cursor sequence and optional dependentEventProcessor(s), using the given WaitStrategy.Fields in com.lmax.disruptor declared as SequenceBarrierModifier and TypeFieldDescriptionprivate final SequenceBarrierBatchEventProcessor.sequenceBarrierMethods in com.lmax.disruptor that return SequenceBarrierModifier and TypeMethodDescriptionAbstractSequencer.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.Methods in com.lmax.disruptor with parameters of type SequenceBarrierModifier and TypeMethodDescriptionprivate intSleepingWaitStrategy.applyWaitMethod(SequenceBarrier barrier, int counter) private intYieldingWaitStrategy.applyWaitMethod(SequenceBarrier barrier, int counter) <T> BatchEventProcessor<T> BatchEventProcessorBuilder.build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandler<? super T> eventHandler) Construct aEventProcessorthat will automatically track the progress by updating its sequence when theEventHandler.onEvent(Object, long, boolean)method returns.<T> BatchEventProcessor<T> BatchEventProcessorBuilder.build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, RewindableEventHandler<? super T> rewindableEventHandler, BatchRewindStrategy batchRewindStrategy) Construct aEventProcessorthat will automatically track the progress by updating its sequence when theEventHandler.onEvent(Object, long, boolean)method returns.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 SequenceBarrierModifierConstructorDescription(package private)BatchEventProcessor(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandlerBase<? super T> eventHandler, int maxBatchSize, BatchRewindStrategy batchRewindStrategy) -
Uses of SequenceBarrier in com.lmax.disruptor.dsl
Fields in com.lmax.disruptor.dsl declared as SequenceBarrierMethods in com.lmax.disruptor.dsl that return SequenceBarrierModifier and TypeMethodDescriptionEventHandlerGroup.asSequenceBarrier()Create a dependency barrier for the processors in this group.ConsumerInfo.getBarrier()EventProcessorInfo.getBarrier()ConsumerRepository.getBarrierFor(EventHandlerIdentity handlerIdentity) Disruptor.getBarrierFor(EventHandlerIdentity handler) Get theSequenceBarrierused by a specific handler.Methods in com.lmax.disruptor.dsl with parameters of type SequenceBarrierModifier and TypeMethodDescriptionvoidConsumerRepository.add(EventProcessor eventprocessor, EventHandlerIdentity handlerIdentity, SequenceBarrier barrier) Constructors in com.lmax.disruptor.dsl with parameters of type SequenceBarrierModifierConstructorDescription(package private)EventProcessorInfo(EventProcessor eventprocessor, SequenceBarrier barrier)