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>
Pulls together the low-level data access and sequencing operations ofRingBuffer
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.Methods in com.lmax.disruptor with parameters of type DataProvider Modifier and Type Method Description <T> BatchEventProcessor<T>
BatchEventProcessorBuilder. build(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.<T> BatchEventProcessor<T>
BatchEventProcessorBuilder. build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, RewindableEventHandler<? super T> rewindableEventHandler, BatchRewindStrategy batchRewindStrategy)
Construct aEventProcessor
that will automatically track the progress by updating its sequence when theEventHandler.onEvent(Object, long, boolean)
method returns.static <T> EventPoller<T>
EventPoller. newInstance(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence cursorSequence, Sequence... gatingSequences)
Creates an event poller.<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)
Creates an event poller from this sequencerConstructors in com.lmax.disruptor with parameters of type DataProvider Constructor Description EventPoller(DataProvider<T> dataProvider, Sequencer sequencer, Sequence sequence, Sequence gatingSequence)
Creates an event poller.
-