Uses of Interface
com.lmax.disruptor.BatchRewindStrategy
Packages that use BatchRewindStrategy
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
A DSL-style API for setting up the disruptor pattern around a ring buffer.
-
Uses of BatchRewindStrategy in com.lmax.disruptor
Classes in com.lmax.disruptor that implement BatchRewindStrategyModifier and TypeClassDescriptionclassStrategy for handling a rewindableException that will eventually delegate the exception to theExceptionHandlerafter a specified number of attempts have been made.classStrategy for handling a rewindableException that will pause for a specified amount of nanos.classBatch rewind strategy that always rewindsFields in com.lmax.disruptor declared as BatchRewindStrategyModifier and TypeFieldDescriptionprivate final BatchRewindStrategyBatchEventProcessor.TryRewindHandler.batchRewindStrategyMethods in com.lmax.disruptor with parameters of type BatchRewindStrategyModifier and TypeMethodDescription<T> BatchEventProcessor<T> BatchEventProcessorBuilder.build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, RewindableEventHandler<? super T> rewindableEventHandler, BatchRewindStrategy batchRewindStrategy) Construct aEventProcessorthat will automatically track the progress by updating its sequence when theEventHandler.onEvent(Object, long, boolean)method returns.Constructors in com.lmax.disruptor with parameters of type BatchRewindStrategyModifierConstructorDescription(package private)BatchEventProcessor(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandlerBase<? super T> eventHandler, int maxBatchSize, BatchRewindStrategy batchRewindStrategy) (package private)TryRewindHandler(BatchRewindStrategy batchRewindStrategy) -
Uses of BatchRewindStrategy in com.lmax.disruptor.dsl
Methods in com.lmax.disruptor.dsl with parameters of type BatchRewindStrategyModifier and TypeMethodDescription(package private) EventHandlerGroup<T> Disruptor.createEventProcessors(Sequence[] barrierSequences, BatchRewindStrategy batchRewindStrategy, RewindableEventHandler<? super T>[] eventHandlers) final EventHandlerGroup<T> Disruptor.handleEventsWith(BatchRewindStrategy batchRewindStrategy, RewindableEventHandler<? super T>... handlers) Set up event handlers to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.handleEventsWith(BatchRewindStrategy batchRewindStrategy, RewindableEventHandler<? super T>... handlers) Set up batch handlers to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.then(BatchRewindStrategy batchRewindStrategy, RewindableEventHandler<? super T>... handlers) Set up batch handlers to consume events from the ring buffer.