Uses of Interface
com.lmax.disruptor.WorkHandler
Packages that use WorkHandler
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
-
Uses of WorkHandler in com.lmax.disruptor
Fields in com.lmax.disruptor declared as WorkHandlerConstructors in com.lmax.disruptor with parameters of type WorkHandlerModifierConstructorDescriptionWorkerPool(EventFactory<T> eventFactory, ExceptionHandler<? super T> exceptionHandler, WorkHandler<? super T>... workHandlers) Construct a work pool with an internalRingBufferfor convenience.WorkerPool(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, ExceptionHandler<? super T> exceptionHandler, WorkHandler<? super T>... workHandlers) Create a worker pool to enable an array ofWorkHandlers to consume published sequences.WorkProcessor(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, WorkHandler<? super T> workHandler, ExceptionHandler<? super T> exceptionHandler, Sequence workSequence) Construct aWorkProcessor. -
Uses of WorkHandler in com.lmax.disruptor.dsl
Methods in com.lmax.disruptor.dsl with parameters of type WorkHandlerModifier and TypeMethodDescription(package private) EventHandlerGroup<T> Disruptor.createWorkerPool(Sequence[] barrierSequences, WorkHandler<? super T>[] workHandlers) 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.thenHandleEventsWithWorkerPool(WorkHandler<? super T>... handlers) Set up a worker pool to handle events from the ring buffer.