void |
SequenceGroup.add(Sequence sequence) |
|
void |
AbstractSequencer.addGatingSequences(Sequence... gatingSequences) |
|
void |
RingBuffer.addGatingSequences(Sequence... gatingSequences) |
Add the specified gating sequences to this instance of the Disruptor.
|
void |
Sequencer.addGatingSequences(Sequence... gatingSequences) |
Add the specified gating sequences to this instance of the Disruptor.
|
void |
SequenceGroup.addWhileRunning(Cursored cursored,
Sequence sequence) |
Adds a sequence to the sequence group after threads have started to publish to
the Disruptor.
|
SequenceBarrier |
AbstractSequencer.newBarrier(Sequence... sequencesToTrack) |
|
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 |
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.
|
static <T> EventPoller<T> |
EventPoller.newInstance(DataProvider<T> dataProvider,
Sequencer sequencer,
Sequence sequence,
Sequence cursorSequence,
Sequence... gatingSequences) |
Creates an event poller.
|
<T> EventPoller<T> |
AbstractSequencer.newPoller(DataProvider<T> dataProvider,
Sequence... gatingSequences) |
Creates an event poller for this sequence that will use the supplied data provider and
gating sequences.
|
EventPoller<E> |
RingBuffer.newPoller(Sequence... gatingSequences) |
Creates an event poller for this ring buffer gated on the supplied sequences.
|
<T> EventPoller<T> |
Sequencer.newPoller(DataProvider<T> provider,
Sequence... gatingSequences) |
Creates an event poller from this sequencer
|
boolean |
SequenceGroup.remove(Sequence sequence) |
Remove the first occurrence of the Sequence from this aggregate.
|
boolean |
AbstractSequencer.removeGatingSequence(Sequence sequence) |
|
boolean |
RingBuffer.removeGatingSequence(Sequence sequence) |
Remove the specified sequence from this ringBuffer.
|
boolean |
Sequencer.removeGatingSequence(Sequence sequence) |
Remove the specified sequence from this sequencer.
|
default void |
EventHandler.setSequenceCallback(Sequence sequenceCallback) |
|
long |
BlockingWaitStrategy.waitFor(long sequence,
Sequence cursorSequence,
Sequence dependentSequence,
SequenceBarrier barrier) |
|
long |
BusySpinWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence dependentSequence,
SequenceBarrier barrier) |
|
long |
LiteBlockingWaitStrategy.waitFor(long sequence,
Sequence cursorSequence,
Sequence dependentSequence,
SequenceBarrier barrier) |
|
long |
LiteTimeoutBlockingWaitStrategy.waitFor(long sequence,
Sequence cursorSequence,
Sequence dependentSequence,
SequenceBarrier barrier) |
|
long |
PhasedBackoffWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence dependentSequence,
SequenceBarrier barrier) |
|
long |
SleepingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence dependentSequence,
SequenceBarrier barrier) |
|
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.
|
long |
YieldingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence dependentSequence,
SequenceBarrier barrier) |
|