Uses of Class
com.lmax.disruptor.dsl.EventHandlerGroup
Packages that use EventHandlerGroup
-
Uses of EventHandlerGroup in com.lmax.disruptor.dsl
Methods in com.lmax.disruptor.dsl that return EventHandlerGroupModifier and TypeMethodDescriptionfinal EventHandlerGroup<T> Disruptor.after(EventHandler<T>... handlers) Create a group of event handlers to be used as a dependency.Disruptor.after(EventProcessor... processors) Create a group of event processors to be used as a dependency.EventHandlerGroup.and(EventHandlerGroup<T> otherHandlerGroup) Create a new event handler group that combines the consumers in this group with otherHandlerGroup.EventHandlerGroup.and(EventProcessor... processors) Create a new event handler group that combines the handlers in this group with processors.(package private) EventHandlerGroup<T> Disruptor.createEventProcessors(Sequence[] barrierSequences, EventProcessorFactory<T>[] processorFactories) (package private) EventHandlerGroup<T> Disruptor.createEventProcessors(Sequence[] barrierSequences, EventHandler<? super T>[] eventHandlers) (package private) EventHandlerGroup<T> Disruptor.createWorkerPool(Sequence[] barrierSequences, WorkHandler<? super T>[] workHandlers) final EventHandlerGroup<T> Disruptor.handleEventsWith(EventProcessorFactory<T>... eventProcessorFactories) Set up custom event processors to handle events from the ring buffer.final EventHandlerGroup<T> Disruptor.handleEventsWith(EventHandler<? super T>... handlers) Set up event handlers to handle events from the ring buffer.Disruptor.handleEventsWith(EventProcessor... processors) Set up custom event processors to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.handleEventsWith(EventProcessorFactory<T>... eventProcessorFactories) Set up custom event processors 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> Disruptor.handleEventsWithWorkerPool(WorkHandler<T>... workHandlers) Set up aWorkerPoolto distribute an event to one of a pool of work handler threads.final EventHandlerGroup<T> EventHandlerGroup.handleEventsWithWorkerPool(WorkHandler<? super T>... handlers) Set up a worker pool to handle events from the ring buffer.final EventHandlerGroup<T> EventHandlerGroup.then(EventProcessorFactory<T>... eventProcessorFactories) Set up custom event processors 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.final EventHandlerGroup<T> EventHandlerGroup.thenHandleEventsWithWorkerPool(WorkHandler<? super T>... handlers) Set up a worker pool to handle events from the ring buffer.Methods in com.lmax.disruptor.dsl with parameters of type EventHandlerGroupModifier and TypeMethodDescriptionEventHandlerGroup.and(EventHandlerGroup<T> otherHandlerGroup) Create a new event handler group that combines the consumers in this group with otherHandlerGroup.