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
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 |
---|---|---|
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.