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 |
Modifier and Type | Method and Description |
---|---|
SequenceBarrier |
AbstractSequencer.newBarrier(Sequence... sequencesToTrack) |
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.
|
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.
|
Modifier and Type | Method and Description |
---|---|
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 |
TimeoutBlockingWaitStrategy.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 |
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) |
long |
LiteTimeoutBlockingWaitStrategy.waitFor(long sequence,
Sequence cursorSequence,
Sequence dependentSequence,
SequenceBarrier barrier) |
Constructor and Description |
---|
BatchEventProcessor(DataProvider<T> dataProvider,
SequenceBarrier sequenceBarrier,
EventHandler<? super T> eventHandler)
Construct a
EventProcessor that will automatically track the progress by updating its sequence when
the EventHandler.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 of
WorkHandler s to consume published sequences. |
WorkProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
WorkHandler<? super T> workHandler,
ExceptionHandler<? super T> exceptionHandler,
Sequence workSequence)
Construct a
WorkProcessor . |
Modifier and Type | Method and Description |
---|---|
SequenceBarrier |
EventHandlerGroup.asSequenceBarrier()
Create a dependency barrier for the processors in this group.
|
SequenceBarrier |
Disruptor.getBarrierFor(EventHandler<T> handler)
Get the
SequenceBarrier used by a specific handler. |
Copyright © 2024. All rights reserved.