| 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 | Method | Description |
|---|---|---|
static <E> RingBuffer<E> |
RingBuffer.create(ProducerType producerType,
EventFactory<E> factory,
int bufferSize,
WaitStrategy waitStrategy) |
Create a new Ring Buffer with the specified producer type (SINGLE or MULTI)
|
static <E> RingBuffer<E> |
RingBuffer.createMultiProducer(EventFactory<E> factory,
int bufferSize) |
Create a new multiple producer RingBuffer using the default wait strategy
BlockingWaitStrategy. |
static <E> RingBuffer<E> |
RingBuffer.createMultiProducer(EventFactory<E> factory,
int bufferSize,
WaitStrategy waitStrategy) |
Create a new multiple producer RingBuffer with the specified wait strategy.
|
static <E> RingBuffer<E> |
RingBuffer.createSingleProducer(EventFactory<E> factory,
int bufferSize) |
Create a new single producer RingBuffer using the default wait strategy
BlockingWaitStrategy. |
static <E> RingBuffer<E> |
RingBuffer.createSingleProducer(EventFactory<E> factory,
int bufferSize,
WaitStrategy waitStrategy) |
Create a new single producer RingBuffer with the specified wait strategy.
|
RingBuffer<T> |
WorkerPool.start(Executor executor) |
Start the worker pool processing events in sequence.
|
| Constructor | Description |
|---|---|
NoOpEventProcessor(RingBuffer<?> sequencer) |
Construct a
EventProcessor that simply tracks a Sequence object. |
WorkerPool(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
ExceptionHandler<? super T> exceptionHandler,
WorkHandler<? super T>... workHandlers) |
Create a worker pool to enable an array of
WorkHandlers 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 |
|---|---|---|
RingBuffer<T> |
Disruptor.getRingBuffer() |
The
RingBuffer used by this Disruptor. |
RingBuffer<T> |
Disruptor.start() |
Starts the event processors and returns the fully configured ring buffer.
|
| Modifier and Type | Method | Description |
|---|---|---|
EventProcessor |
EventProcessorFactory.createEventProcessor(RingBuffer<T> ringBuffer,
Sequence[] barrierSequences) |
Create a new event processor that gates on
barrierSequences. |
Copyright © 2019. All rights reserved.