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 A DSL-style API for setting up the disruptor pattern around a ring buffer.com.lmax.disruptor.util Utility classes -
-
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
. -
Uses of EventProcessor in com.lmax.disruptor.dsl
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
.Methods in com.lmax.disruptor.dsl with parameters of type EventProcessor Modifier and Type Method Description 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 withprocessors
.EventHandlerGroup<T>
Disruptor. handleEventsWith(EventProcessor... processors)
Set up custom event processors to handle events from the ring buffer. -
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.
-