|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use SequenceBarrier | |
|---|---|
| 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 | |
| Uses of SequenceBarrier in com.lmax.disruptor |
|---|
| Methods in com.lmax.disruptor that return SequenceBarrier | |
|---|---|
SequenceBarrier |
Sequencer.newBarrier(Sequence... sequencesToTrack)
Create a SequenceBarrier that gates on the the cursor and a list of Sequences |
| Methods in com.lmax.disruptor with parameters of type SequenceBarrier | |
|---|---|
long |
BusySpinWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier)
|
long |
BlockingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier)
|
long |
YieldingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier)
|
long |
SleepingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier)
|
long |
WaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier)
Wait for the given sequence to be available |
long |
BusySpinWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier,
long timeout,
java.util.concurrent.TimeUnit sourceUnit)
|
long |
BlockingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier,
long timeout,
java.util.concurrent.TimeUnit sourceUnit)
|
long |
YieldingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier,
long timeout,
java.util.concurrent.TimeUnit sourceUnit)
|
long |
SleepingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier,
long timeout,
java.util.concurrent.TimeUnit sourceUnit)
|
long |
WaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence[] dependents,
SequenceBarrier barrier,
long timeout,
java.util.concurrent.TimeUnit sourceUnit)
Wait for the given sequence to be available with a timeout specified. |
| Constructors in com.lmax.disruptor with parameters of type SequenceBarrier | |
|---|---|
BatchEventProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
EventHandler<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 exceptionHandler,
WorkHandler<T>... workHandlers)
Create a worker pool to enable an array of WorkHandlers to consume published sequences. |
|
WorkProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
WorkHandler<T> workHandler,
ExceptionHandler exceptionHandler,
Sequence workSequence)
Construct a WorkProcessor. |
|
| Uses of SequenceBarrier in com.lmax.disruptor.dsl |
|---|
| Methods in com.lmax.disruptor.dsl that return SequenceBarrier | |
|---|---|
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. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||