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 | Interface and Description |
---|---|
interface |
EventSequencer<T> |
Modifier and Type | Class and Description |
---|---|
class |
RingBuffer<E>
Ring based store of reusable entries containing the data representing
an event being exchanged between event producer and
EventProcessor s. |
Modifier and Type | Field and Description |
---|---|
private DataProvider<T> |
BatchEventProcessor.dataProvider |
private DataProvider<T> |
EventPoller.dataProvider |
Modifier and Type | Method and Description |
---|---|
static <T> EventPoller<T> |
EventPoller.newInstance(DataProvider<T> dataProvider,
Sequencer sequencer,
Sequence sequence,
Sequence cursorSequence,
Sequence... gatingSequences) |
<T> EventPoller<T> |
Sequencer.newPoller(DataProvider<T> provider,
Sequence... gatingSequences) |
<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.
|
Constructor and Description |
---|
BatchEventProcessor(DataProvider<T> dataProvider,
SequenceBarrier sequenceBarrier,
EventHandler<? super T> eventHandler)
Construct a
EventProcessor that will automatically track the progress by updating its sequence when
the EventHandler.onEvent(Object, long, boolean) method returns. |
EventPoller(DataProvider<T> dataProvider,
Sequencer sequencer,
Sequence sequence,
Sequence gatingSequence) |