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 |
Constructor | 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 | Description |
---|---|---|
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.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.
|
Copyright © 2019. All rights reserved.