Package | Description |
---|---|
com.lmax.disruptor |
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
|
Modifier and Type | Field and Description |
---|---|
static AlertException |
AlertException.INSTANCE
Pre-allocated exception to avoid garbage generation
|
Modifier and Type | Method and Description |
---|---|
private int |
YieldingWaitStrategy.applyWaitMethod(SequenceBarrier barrier,
int counter) |
private int |
SleepingWaitStrategy.applyWaitMethod(SequenceBarrier barrier,
int counter) |
void |
ProcessingSequenceBarrier.checkAlert() |
void |
SequenceBarrier.checkAlert()
Check if an alert has been raised and throw an
AlertException if it has. |
long |
ProcessingSequenceBarrier.waitFor(long sequence) |
long |
SequenceBarrier.waitFor(long sequence)
Wait for the given sequence to be available for consumption.
|
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.
|