Uses of Class
com.lmax.disruptor.RingBuffer
Packages that use RingBuffer
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
-
Uses of RingBuffer in com.lmax.disruptor
Fields in com.lmax.disruptor declared as RingBufferModifier and TypeFieldDescriptionprivate final RingBuffer
<T> WorkerPool.ringBuffer
private final RingBuffer
<T> WorkProcessor.ringBuffer
private final RingBuffer
<?> NoOpEventProcessor.SequencerFollowingSequence.sequencer
Methods in com.lmax.disruptor that return RingBufferModifier and TypeMethodDescriptionstatic <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 strategyBlockingWaitStrategy
.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 strategyBlockingWaitStrategy
.static <E> RingBuffer
<E> RingBuffer.createSingleProducer
(EventFactory<E> factory, int bufferSize, WaitStrategy waitStrategy) Create a new single producer RingBuffer with the specified wait strategy.Start the worker pool processing events in sequence.Constructors in com.lmax.disruptor with parameters of type RingBufferModifierConstructorDescriptionNoOpEventProcessor
(RingBuffer<?> sequencer) Construct aEventProcessor
that simply tracks aSequence
object.private
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 ofWorkHandler
s to consume published sequences.WorkProcessor
(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, WorkHandler<? super T> workHandler, ExceptionHandler<? super T> exceptionHandler, Sequence workSequence) Construct aWorkProcessor
. -
Uses of RingBuffer in com.lmax.disruptor.dsl
Fields in com.lmax.disruptor.dsl declared as RingBufferMethods in com.lmax.disruptor.dsl that return RingBufferModifier and TypeMethodDescriptionDisruptor.getRingBuffer()
TheRingBuffer
used by this Disruptor.Disruptor.start()
Starts the event processors and returns the fully configured ring buffer.Methods in com.lmax.disruptor.dsl with parameters of type RingBufferModifier and TypeMethodDescriptionEventProcessorFactory.createEventProcessor
(RingBuffer<T> ringBuffer, Sequence[] barrierSequences) Create a new event processor that gates onbarrierSequences
.Constructors in com.lmax.disruptor.dsl with parameters of type RingBufferModifierConstructorDescriptionprivate
Disruptor
(RingBuffer<T> ringBuffer, Executor executor) Private constructor helper