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.ringBufferprivate final RingBuffer<T> WorkProcessor.ringBufferprivate final RingBuffer<?> NoOpEventProcessor.SequencerFollowingSequence.sequencerMethods 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.privateSequencerFollowingSequence(RingBuffer<?> sequencer) 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
Fields in com.lmax.disruptor.dsl declared as RingBufferMethods 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.Constructors in com.lmax.disruptor.dsl with parameters of type RingBufferModifierConstructorDescriptionprivateDisruptor(RingBuffer<T> ringBuffer, Executor executor) Private constructor helper