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 | 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.
|
EventPoller<E> |
RingBuffer.newPoller(Sequence... gatingSequences)
Creates an event poller for this ring buffer gated on the supplied sequences.
|