Package com.lmax.disruptor
Class EventPoller<T>
- java.lang.Object
-
- com.lmax.disruptor.EventPoller<T>
-
public class EventPoller<T> extends java.lang.Object
Experimental poll-based interface for the Disruptor.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
EventPoller.Handler<T>
static class
EventPoller.PollState
-
Field Summary
Fields Modifier and Type Field Description private DataProvider<T>
dataProvider
private Sequence
gatingSequence
private Sequence
sequence
private Sequencer
sequencer
-
Constructor Summary
Constructors Constructor Description EventPoller(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description Sequence
getSequence()
static <T> EventPoller<T>
newInstance(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence cursorSequence, Sequence... gatingSequences)
EventPoller.PollState
poll(EventPoller.Handler<T> eventHandler)
-
-
-
Field Detail
-
dataProvider
private final DataProvider<T> dataProvider
-
sequencer
private final Sequencer sequencer
-
sequence
private final Sequence sequence
-
gatingSequence
private final Sequence gatingSequence
-
-
Constructor Detail
-
EventPoller
public EventPoller(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence)
-
-
Method Detail
-
poll
public EventPoller.PollState poll(EventPoller.Handler<T> eventHandler) throws java.lang.Exception
- Throws:
java.lang.Exception
-
newInstance
public static <T> EventPoller<T> newInstance(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence cursorSequence, Sequence... gatingSequences)
-
getSequence
public Sequence getSequence()
-
-