Uses of Interface
com.lmax.disruptor.EventProcessor
-
Packages that use EventProcessor Package Description com.lmax.disruptor The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.com.lmax.disruptor.dsl com.lmax.disruptor.util -
-
Uses of EventProcessor in com.lmax.disruptor
Classes in com.lmax.disruptor that implement EventProcessor Modifier and Type Class Description class
BatchEventProcessor<T>
Convenience class for handling the batching semantics of consuming entries from aRingBuffer
and delegating the available events to anEventHandler
.class
NoOpEventProcessor
No operation version of aEventProcessor
that simply tracks aSequence
.class
WorkProcessor<T>
AWorkProcessor
wraps a singleWorkHandler
, effectively consuming the sequence and ensuring appropriate barriers. -
Uses of EventProcessor in com.lmax.disruptor.dsl
Fields in com.lmax.disruptor.dsl declared as EventProcessor Modifier and Type Field Description private EventProcessor
EventProcessorInfo. eventprocessor
Methods in com.lmax.disruptor.dsl that return EventProcessor Modifier and Type Method Description EventProcessor
EventProcessorFactory. createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences)
Create a new event processor that gates onbarrierSequences
.EventProcessor
EventProcessorInfo. getEventProcessor()
EventProcessor
ConsumerRepository. getEventProcessorFor(EventHandler<T> handler)
Methods in com.lmax.disruptor.dsl with parameters of type EventProcessor Modifier and Type Method Description void
ConsumerRepository. add(EventProcessor processor)
void
ConsumerRepository. add(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
EventHandlerGroup<T>
Disruptor. after(EventProcessor... processors)
Create a group of event processors to be used as a dependency.EventHandlerGroup<T>
EventHandlerGroup. and(EventProcessor... processors)
Create a new event handler group that combines the handlers in this group with processors.EventHandlerGroup<T>
Disruptor. handleEventsWith(EventProcessor... processors)
Set up custom event processors to handle events from the ring buffer.Constructors in com.lmax.disruptor.dsl with parameters of type EventProcessor Constructor Description EventProcessorInfo(EventProcessor eventprocessor, EventHandler<? super T> handler, SequenceBarrier barrier)
-
Uses of EventProcessor in com.lmax.disruptor.util
Methods in com.lmax.disruptor.util with parameters of type EventProcessor Modifier and Type Method Description static Sequence[]
Util. getSequencesFor(EventProcessor... processors)
Get an array ofSequence
s for the passedEventProcessor
s
-