Uses of Interface
com.lmax.disruptor.DataProvider
-
Packages that use DataProvider Package Description com.lmax.disruptor The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events. -
-
Uses of DataProvider in com.lmax.disruptor
Subinterfaces of DataProvider in com.lmax.disruptor Modifier and Type Interface Description interface
EventSequencer<T>
Classes in com.lmax.disruptor that implement DataProvider 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 andEventProcessor
s.Fields in com.lmax.disruptor declared as DataProvider Modifier and Type Field Description private DataProvider<T>
BatchEventProcessor. dataProvider
private DataProvider<T>
EventPoller. dataProvider
Methods in com.lmax.disruptor with parameters of type DataProvider 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)
Constructors in com.lmax.disruptor with parameters of type DataProvider Constructor Description BatchEventProcessor(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandler<? super T> eventHandler)
Construct aEventProcessor
that will automatically track the progress by updating its sequence when theEventHandler.onEvent(Object, long, boolean)
method returns.EventPoller(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence)
-