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 | Field and Description |
---|---|
private RingBuffer<T> |
WorkerPool.ringBuffer |
private RingBuffer<T> |
WorkProcessor.ringBuffer |
private RingBuffer<?> |
NoOpEventProcessor.SequencerFollowingSequence.sequencer |
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(java.util.concurrent.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. |
SequencerFollowingSequence(RingBuffer<?> sequencer) |
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 | Field and Description |
---|---|
private RingBuffer<T> |
Disruptor.ringBuffer |
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.
|
Modifier and Type | Method and Description |
---|---|
EventProcessor |
EventProcessorFactory.createEventProcessor(RingBuffer<T> ringBuffer,
Sequence[] barrierSequences)
Create a new event processor that gates on
barrierSequences . |
Constructor and Description |
---|
Disruptor(RingBuffer<T> ringBuffer,
java.util.concurrent.Executor executor)
Private constructor helper
|