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 |
Modifier and Type | Field and Description |
---|---|
private WorkHandler<? super T> |
WorkProcessor.workHandler |
Constructor and Description |
---|
WorkerPool(EventFactory<T> eventFactory,
ExceptionHandler<? super T> exceptionHandler,
WorkHandler<? super T>... workHandlers)
Construct a work pool with an internal
RingBuffer for convenience. |
WorkerPool(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
ExceptionHandler<? super T> exceptionHandler,
WorkHandler<? super T>... workHandlers)
Create a worker pool to enable an array of
WorkHandler s to consume published sequences. |
WorkProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
WorkHandler<? super T> workHandler,
ExceptionHandler<? super T> exceptionHandler,
Sequence workSequence)
Construct a
WorkProcessor . |
Modifier and Type | Method and Description |
---|---|
(package private) EventHandlerGroup<T> |
Disruptor.createWorkerPool(Sequence[] barrierSequences,
WorkHandler<? super T>[] workHandlers) |
EventHandlerGroup<T> |
EventHandlerGroup.handleEventsWithWorkerPool(WorkHandler<? super T>... handlers)
Set up a worker pool to handle events from the ring buffer.
|
EventHandlerGroup<T> |
Disruptor.handleEventsWithWorkerPool(WorkHandler<T>... workHandlers)
Set up a
WorkerPool to distribute an event to one of a pool of work handler threads. |
EventHandlerGroup<T> |
EventHandlerGroup.thenHandleEventsWithWorkerPool(WorkHandler<? super T>... handlers)
Set up a worker pool to handle events from the ring buffer.
|