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 | Field and Description |
---|---|
static TimeoutException |
TimeoutException.INSTANCE |
Modifier and Type | Method and Description |
---|---|
long |
ProcessingSequenceBarrier.waitFor(long sequence) |
long |
SequenceBarrier.waitFor(long sequence)
Wait for the given sequence to be available for consumption.
|
long |
PhasedBackoffWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence dependentSequence,
SequenceBarrier barrier) |
long |
TimeoutBlockingWaitStrategy.waitFor(long sequence,
Sequence cursorSequence,
Sequence dependentSequence,
SequenceBarrier barrier) |
long |
LiteTimeoutBlockingWaitStrategy.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.
|
Modifier and Type | Method and Description |
---|---|
void |
Disruptor.shutdown(long timeout,
java.util.concurrent.TimeUnit timeUnit)
Waits until all events currently in the disruptor have been processed by all event processors
and then halts the processors.
|