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 interfacestatic enum -
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final DataProvider<T> private final Sequenceprivate final Sequenceprivate 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
-