| Constructors in com.lmax.disruptor with parameters of type WorkHandler |
WorkerPool(EventFactory<T> eventFactory,
ClaimStrategy claimStrategy,
WaitStrategy waitStrategy,
ExceptionHandler exceptionHandler,
WorkHandler<T>... workHandlers)
Construct a work pool with an internal RingBuffer for convenience. |
WorkerPool(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
ExceptionHandler exceptionHandler,
WorkHandler<T>... workHandlers)
Create a worker pool to enable an array of WorkHandlers to consume published sequences. |
WorkProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
WorkHandler<T> workHandler,
ExceptionHandler exceptionHandler,
Sequence workSequence)
Construct a WorkProcessor. |