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 | Description |
---|---|---|
interface |
EventSequencer<T> |
Modifier and Type | Class | 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 | Method | Description |
---|---|---|
static <T> EventPoller<T> |
EventPoller.newInstance(DataProvider<T> dataProvider,
Sequencer sequencer,
Sequence sequence,
Sequence cursorSequence,
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.
|
<T> EventPoller<T> |
Sequencer.newPoller(DataProvider<T> provider,
Sequence... gatingSequences) |
Constructor | 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) |
Copyright © 2019. All rights reserved.