Uses of Interface
com.lmax.disruptor.WorkHandler
-
Packages that use WorkHandler 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 -
-
Uses of WorkHandler in com.lmax.disruptor
Fields in com.lmax.disruptor declared as WorkHandler Modifier and Type Field Description private WorkHandler<? super T>
WorkProcessor. workHandler
Constructors in com.lmax.disruptor with parameters of type WorkHandler Constructor Description WorkerPool(EventFactory<T> eventFactory, ExceptionHandler<? super T> exceptionHandler, WorkHandler<? super T>... workHandlers)
Construct a work pool with an internalRingBuffer
for convenience.WorkerPool(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, ExceptionHandler<? super T> exceptionHandler, WorkHandler<? super T>... workHandlers)
Create a worker pool to enable an array ofWorkHandler
s 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 WorkHandler Modifier and Type Method Description (package private) EventHandlerGroup<T>
Disruptor. createWorkerPool(Sequence[] barrierSequences, WorkHandler<? super T>[] workHandlers)
EventHandlerGroup<T>
Disruptor. handleEventsWithWorkerPool(WorkHandler<T>... workHandlers)
Set up aWorkerPool
to distribute an event to one of a pool of work handler threads.EventHandlerGroup<T>
EventHandlerGroup. handleEventsWithWorkerPool(WorkHandler<? super T>... handlers)
Set up a worker pool to handle events from the ring buffer.EventHandlerGroup<T>
EventHandlerGroup. thenHandleEventsWithWorkerPool(WorkHandler<? super T>... handlers)
Set up a worker pool to handle events from the ring buffer.
-