Uses of Interface
com.lmax.disruptor.SequenceBarrier
-
Packages that use SequenceBarrier 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 A DSL-style API for setting up the disruptor pattern around a ring buffer. -
-
Uses of SequenceBarrier in com.lmax.disruptor
Methods in com.lmax.disruptor that return SequenceBarrier Modifier and Type Method Description 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.Methods in com.lmax.disruptor with parameters of type SequenceBarrier Modifier and Type Method Description <T> BatchEventProcessor<T>
BatchEventProcessorBuilder. build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandler<? super T> eventHandler)
Construct aEventProcessor
that 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 aEventProcessor
that will automatically track the progress by updating its sequence when theEventHandler.onEvent(Object, long, boolean)
method returns.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)
-
Uses of SequenceBarrier in com.lmax.disruptor.dsl
Methods in com.lmax.disruptor.dsl that return SequenceBarrier Modifier and Type Method Description SequenceBarrier
EventHandlerGroup. asSequenceBarrier()
Create a dependency barrier for the processors in this group.SequenceBarrier
Disruptor. getBarrierFor(EventHandlerIdentity handler)
Get theSequenceBarrier
used by a specific handler.
-