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 -
-
Uses of SequenceBarrier in com.lmax.disruptor
Classes in com.lmax.disruptor that implement SequenceBarrier Modifier and Type Class Description (package private) class
ProcessingSequenceBarrier
SequenceBarrier
handed out for gatingEventProcessor
s on a cursor sequence and optional dependentEventProcessor
(s), using the given WaitStrategy.Fields in com.lmax.disruptor declared as SequenceBarrier Modifier and Type Field Description private SequenceBarrier
BatchEventProcessor. sequenceBarrier
private SequenceBarrier
WorkProcessor. sequenceBarrier
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 private int
SleepingWaitStrategy. applyWaitMethod(SequenceBarrier barrier, int counter)
private int
YieldingWaitStrategy. applyWaitMethod(SequenceBarrier barrier, int counter)
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 SequenceBarrier Constructor Description BatchEventProcessor(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.WorkerPool(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, ExceptionHandler<? super T> exceptionHandler, WorkHandler<? super T>... workHandlers)
Create a worker pool to enable an array ofWorkHandler
s to consume published sequences.WorkProcessor(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, WorkHandler<? super T> workHandler, ExceptionHandler<? super T> exceptionHandler, Sequence workSequence)
Construct aWorkProcessor
. -
Uses of SequenceBarrier in com.lmax.disruptor.dsl
Fields in com.lmax.disruptor.dsl declared as SequenceBarrier Modifier and Type Field Description private SequenceBarrier
EventProcessorInfo. barrier
private SequenceBarrier
WorkerPoolInfo. sequenceBarrier
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
ConsumerInfo. getBarrier()
SequenceBarrier
EventProcessorInfo. getBarrier()
SequenceBarrier
WorkerPoolInfo. getBarrier()
SequenceBarrier
ConsumerRepository. getBarrierFor(EventHandler<T> handler)
SequenceBarrier
Disruptor. getBarrierFor(EventHandler<T> handler)
Get theSequenceBarrier
used by a specific handler.Methods in com.lmax.disruptor.dsl with parameters of type SequenceBarrier Modifier and Type Method Description void
ConsumerRepository. add(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
void
ConsumerRepository. add(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)
Constructors in com.lmax.disruptor.dsl with parameters of type SequenceBarrier Constructor Description EventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
WorkerPoolInfo(WorkerPool<T> workerPool, SequenceBarrier sequenceBarrier)
-