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.util |
Modifier and Type | Class and Description |
---|---|
class |
FixedSequenceGroup
Hides a group of Sequences behind a single Sequence
|
class |
SequenceGroup
|
Modifier and Type | Field and Description |
---|---|
protected Sequence |
AbstractSequencer.cursor |
protected Sequence[] |
AbstractSequencer.gatingSequences |
Modifier and Type | Method and Description |
---|---|
Sequence |
BatchEventProcessor.getSequence() |
Sequence |
WorkProcessor.getSequence() |
Sequence |
NoOpEventProcessor.getSequence() |
Sequence |
EventProcessor.getSequence()
Get a reference to the
Sequence being used by this EventProcessor . |
Sequence[] |
WorkerPool.getWorkerSequences()
Get an array of
Sequence s representing the progress of the workers. |
Modifier and Type | Method and Description |
---|---|
void |
SequenceGroup.add(Sequence sequence)
Add a
Sequence into this aggregate. |
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.
|
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.
|
void |
SequenceReportingEventHandler.setSequenceCallback(Sequence sequenceCallback)
Call by the
BatchEventProcessor to setup the callback. |
long |
SleepingWaitStrategy.waitFor(long sequence,
Sequence cursor,
Sequence dependentSequence,
SequenceBarrier barrier) |
long |
PhasedBackoffWaitStrategy.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.
|
long |
TimeoutBlockingWaitStrategy.waitFor(long sequence,
Sequence cursorSequence,
Sequence dependentSequence,
SequenceBarrier barrier) |
long |
YieldingWaitStrategy.waitFor(long sequence,
Sequence cursor,
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) |
Constructor and Description |
---|
FixedSequenceGroup(Sequence[] sequences)
Constructor
|
WorkProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
WorkHandler<T> workHandler,
ExceptionHandler exceptionHandler,
Sequence workSequence)
Construct a
WorkProcessor . |
Modifier and Type | Method and Description |
---|---|
static Sequence[] |
Util.getSequencesFor(EventProcessor... processors)
Get an array of
Sequence s for the passed EventProcessor s |
Modifier and Type | Method and Description |
---|---|
static long |
Util.getMinimumSequence(Sequence[] sequences)
Get the minimum sequence from an array of
Sequence s. |
static long |
Util.getMinimumSequence(Sequence[] sequences,
long minimum)
Get the minimum sequence from an array of
Sequence s. |
Copyright © 2015. All rights reserved.