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 and 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 and Description |
---|
NoOpEventProcessor(RingBuffer<?> sequencer)
Construct a
EventProcessor that simply tracks a Sequence object. |
WorkerPool(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
ExceptionHandler exceptionHandler,
WorkHandler<T>... workHandlers)
Create a worker pool to enable an array of
WorkHandler s to consume published sequences. |
WorkProcessor(RingBuffer<T> ringBuffer,
SequenceBarrier sequenceBarrier,
WorkHandler<T> workHandler,
ExceptionHandler exceptionHandler,
Sequence workSequence)
Construct a
WorkProcessor . |
Modifier and Type | Method and 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.
|
Copyright © 2016. All rights reserved.