Uses of Interface
com.lmax.disruptor.EventProcessor
Packages that use EventProcessor
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.
Utility classes
-
Uses of EventProcessor in com.lmax.disruptor
Classes in com.lmax.disruptor that implement EventProcessorModifier and TypeClassDescriptionfinal classConvenience class for handling the batching semantics of consuming entries from aRingBufferand delegating the available events to anEventHandler.final classNo operation version of aEventProcessorthat simply tracks aSequence. -
Uses of EventProcessor in com.lmax.disruptor.dsl
Fields in com.lmax.disruptor.dsl declared as EventProcessorMethods in com.lmax.disruptor.dsl that return EventProcessorModifier and TypeMethodDescriptionEventProcessorFactory.createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences) Create a new event processor that gates onbarrierSequences.EventProcessorInfo.getEventProcessor()ConsumerRepository.getEventProcessorFor(EventHandlerIdentity handlerIdentity) Methods in com.lmax.disruptor.dsl with parameters of type EventProcessorModifier and TypeMethodDescriptionvoidConsumerRepository.add(EventProcessor processor) voidConsumerRepository.add(EventProcessor eventprocessor, EventHandlerIdentity handlerIdentity, SequenceBarrier barrier) Disruptor.after(EventProcessor... processors) Create a group of event processors to be used as a dependency.EventHandlerGroup.and(EventProcessor... processors) Create a new event handler group that combines the handlers in this group withprocessors.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 EventProcessorModifierConstructorDescription(package private)EventProcessorInfo(EventProcessor eventprocessor, SequenceBarrier barrier) -
Uses of EventProcessor in com.lmax.disruptor.util
Methods in com.lmax.disruptor.util with parameters of type EventProcessorModifier and TypeMethodDescriptionstatic Sequence[]Util.getSequencesFor(EventProcessor... processors) Get an array ofSequences for the passedEventProcessors.