|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||
| Packages that use RingBuffer | |
|---|---|
| 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 RingBuffer in com.lmax.disruptor |
|---|
| Methods in com.lmax.disruptor that return RingBuffer | |
|---|---|
RingBuffer<T> |
WorkerPool.start(java.util.concurrent.Executor executor)
Start the worker pool processing events in sequence. |
| Constructors in com.lmax.disruptor with parameters of type RingBuffer | |
|---|---|
BatchEventProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
EventHandler<T> eventHandler)
Construct a EventProcessor that will automatically track the progress by updating its sequence when
the EventHandler.onEvent(Object, long, boolean) method returns. |
|
EventPublisher(RingBuffer<E> ringBuffer)
Construct from the ring buffer to be published to. |
|
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. |
|
| Uses of RingBuffer in com.lmax.disruptor.dsl |
|---|
| Methods in com.lmax.disruptor.dsl that return RingBuffer | |
|---|---|
RingBuffer<T> |
Disruptor.getRingBuffer()
The the RingBuffer used by this Disruptor. |
RingBuffer<T> |
Disruptor.start()
Starts the event processors and returns the fully configured ring buffer. |
|
||||||||||
| PREV NEXT | FRAMES NO FRAMES | |||||||||