Uses of Interface
com.lmax.disruptor.EventHandler
Packages that use EventHandler
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 EventHandler in com.lmax.disruptor
Subinterfaces of EventHandler in com.lmax.disruptorModifier and TypeInterfaceDescriptioninterfaceUsed by theBatchEventProcessorto set a callback allowing theEventHandlerto notify when it has finished consuming an event if this happens after theonEvent(Object, long, boolean)call.Classes in com.lmax.disruptor that implement EventHandlerModifier and TypeClassDescriptionfinal classAn aggregate collection ofEventHandlers that get called in sequence for each event.Fields in com.lmax.disruptor declared as EventHandlerModifier and TypeFieldDescriptionprivate final EventHandler<T>[]AggregateEventHandler.eventHandlersMethods in com.lmax.disruptor with parameters of type EventHandlerModifier and TypeMethodDescription<T> BatchEventProcessor<T> BatchEventProcessorBuilder.build(DataProvider<T> dataProvider, SequenceBarrier sequenceBarrier, EventHandler<? super T> eventHandler) Construct aEventProcessorthat will automatically track the progress by updating its sequence when theonEvent(Object, long, boolean)method returns.Constructors in com.lmax.disruptor with parameters of type EventHandlerModifierConstructorDescriptionAggregateEventHandler(EventHandler<T>... eventHandlers) Construct an aggregate collection ofEventHandlers to be called in sequence. -
Uses of EventHandler in com.lmax.disruptor.dsl
Methods in com.lmax.disruptor.dsl with parameters of type EventHandlerModifier and TypeMethodDescription(package private) EventHandlerGroup<T> Disruptor.createEventProcessors(Sequence[] barrierSequences, EventHandler<? super T>[] eventHandlers) final EventHandlerGroup<T> Disruptor.handleEventsWith(EventHandler<? super T>... handlers) Set up event handlers to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.handleEventsWith(EventHandler<? super T>... handlers) Set up batch handlers to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.then(EventHandler<? super T>... handlers) Set up batch handlers to consume events from the ring buffer.