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