Package com.lmax.disruptor
Class EventPoller<T>
java.lang.Object
com.lmax.disruptor.EventPoller<T>
Experimental poll-based interface for the Disruptor.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionstatic interface
static enum
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final DataProvider
<T> private final Sequence
private final Sequence
private final Sequencer
-
Constructor Summary
ConstructorsConstructorDescriptionEventPoller
(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence) -
Method Summary
Modifier and TypeMethodDescriptionstatic <T> EventPoller
<T> newInstance
(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence cursorSequence, Sequence... gatingSequences) poll
(EventPoller.Handler<T> eventHandler)
-
Field Details
-
dataProvider
-
sequencer
-
sequence
-
gatingSequence
-
-
Constructor Details
-
EventPoller
public EventPoller(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence)
-
-
Method Details
-
poll
- Throws:
Exception
-
newInstance
public static <T> EventPoller<T> newInstance(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence cursorSequence, Sequence... gatingSequences) -
getSequence
-