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
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 aEventProcessorthat simply tracks aSequenceobject.WorkerPool(RingBuffer<T> ringBuffer, SequenceBarrier sequenceBarrier, ExceptionHandler<? super T> exceptionHandler, WorkHandler<? super T>... workHandlers) Create a worker pool to enable an array ofWorkHandlers 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
Methods in com.lmax.disruptor.dsl that return RingBufferModifier and TypeMethodDescriptionDisruptor.getRingBuffer()TheRingBufferused 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.