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 | Class and Description |
---|---|
(package private) class |
ProcessingSequenceBarrier
SequenceBarrier handed out for gating EventProcessor s on a cursor sequence and optional dependent EventProcessor (s),
using the given WaitStrategy. |
Modifier and Type | Field and Description |
---|---|
private SequenceBarrier |
WorkProcessor.sequenceBarrier |
private SequenceBarrier |
BatchEventProcessor.sequenceBarrier |
Modifier and Type | Method and Description |
---|---|
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.
|
SequenceBarrier |
AbstractSequencer.newBarrier(Sequence... sequencesToTrack) |
Modifier and Type | Method and Description |
---|---|
private int |
YieldingWaitStrategy.applyWaitMethod(SequenceBarrier barrier,
int counter) |
private int |
SleepingWaitStrategy.applyWaitMethod(SequenceBarrier barrier,
int counter) |
long |
YieldingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence dependentSequence,
SequenceBarrier barrier) |
long |
PhasedBackoffWaitStrategy.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 |
BusySpinWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence dependentSequence,
SequenceBarrier barrier) |
long |
BlockingWaitStrategy.waitFor(long sequence,
Sequence cursorSequence,
Sequence dependentSequence,
SequenceBarrier barrier) |
long |
LiteTimeoutBlockingWaitStrategy.waitFor(long sequence,
Sequence cursorSequence,
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.
|
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 | Field and Description |
---|---|
private SequenceBarrier |
EventProcessorInfo.barrier |
private SequenceBarrier |
WorkerPoolInfo.sequenceBarrier |
Modifier and Type | Method and Description |
---|---|
SequenceBarrier |
EventHandlerGroup.asSequenceBarrier()
Create a dependency barrier for the processors in this group.
|
SequenceBarrier |
ConsumerInfo.getBarrier() |
SequenceBarrier |
WorkerPoolInfo.getBarrier() |
SequenceBarrier |
EventProcessorInfo.getBarrier() |
SequenceBarrier |
Disruptor.getBarrierFor(EventHandler<T> handler)
Get the
SequenceBarrier used by a specific handler. |
SequenceBarrier |
ConsumerRepository.getBarrierFor(EventHandler<T> handler) |
Modifier and Type | Method and Description |
---|---|
void |
ConsumerRepository.add(EventProcessor eventprocessor,
EventHandler<? super T> handler,
SequenceBarrier barrier) |
void |
ConsumerRepository.add(WorkerPool<T> workerPool,
SequenceBarrier sequenceBarrier) |
Constructor and Description |
---|
EventProcessorInfo(EventProcessor eventprocessor,
EventHandler<? super T> handler,
SequenceBarrier barrier) |
WorkerPoolInfo(WorkerPool<T> workerPool,
SequenceBarrier sequenceBarrier) |