Uses of Class
com.lmax.disruptor.RingBuffer
-
Packages that use RingBuffer 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 -
-
Uses of RingBuffer in com.lmax.disruptor
Fields in com.lmax.disruptor declared as RingBuffer Modifier and Type Field Description private RingBuffer<T>
WorkerPool. ringBuffer
private RingBuffer<T>
WorkProcessor. ringBuffer
private RingBuffer<?>
NoOpEventProcessor.SequencerFollowingSequence. sequencer
Methods in com.lmax.disruptor that return RingBuffer 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 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.RingBuffer<T>
WorkerPool. start(java.util.concurrent.Executor executor)
Start the worker pool processing events in sequence.Constructors in com.lmax.disruptor with parameters of type RingBuffer Constructor Description NoOpEventProcessor(RingBuffer<?> sequencer)
Construct aEventProcessor
that simply tracks aSequence
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 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 RingBuffer Modifier and Type Field Description private RingBuffer<T>
Disruptor. ringBuffer
Methods in com.lmax.disruptor.dsl that return RingBuffer Modifier and Type Method Description RingBuffer<T>
Disruptor. getRingBuffer()
TheRingBuffer
used by this Disruptor.RingBuffer<T>
Disruptor. start()
Starts the event processors and returns the fully configured ring buffer.Methods in com.lmax.disruptor.dsl with parameters of type RingBuffer Modifier and Type Method Description EventProcessor
EventProcessorFactory. createEventProcessor(RingBuffer<T> ringBuffer, Sequence[] barrierSequences)
Create a new event processor that gates onbarrierSequences
.Constructors in com.lmax.disruptor.dsl with parameters of type RingBuffer Constructor Description Disruptor(RingBuffer<T> ringBuffer, java.util.concurrent.Executor executor)
Private constructor helper
-