Uses of Interface
com.lmax.disruptor.WaitStrategy
Packages that use WaitStrategy
Package
Description
The Disruptor is a concurrent programming framework for exchanging and coordinating work as a continuous series of events.
-
Uses of WaitStrategy in com.lmax.disruptor
Classes in com.lmax.disruptor that implement WaitStrategyModifier and TypeClassDescriptionfinal classBlocking strategy that uses a lock and condition variable forEventProcessors waiting on a barrier.final classBusy Spin strategy that uses a busy spin loop forEventProcessors waiting on a barrier.final classVariation of theBlockingWaitStrategythat attempts to elide conditional wake-ups when the lock is uncontended.classVariation of theTimeoutBlockingWaitStrategythat attempts to elide conditional wake-ups when the lock is uncontended.final classPhased wait strategy for waitingEventProcessors on a barrier.final classSleeping strategy that initially spins, then uses a Thread.yield(), and eventually sleep (LockSupport.parkNanos(n)) for the minimum number of nanos the OS and JVM will allow while theEventProcessors are waiting on a barrier.classfinal classYielding strategy that uses a Thread.yield() forEventProcessors waiting on a barrier after an initially spinning.Fields in com.lmax.disruptor declared as WaitStrategyModifier and TypeFieldDescriptionprivate final WaitStrategyPhasedBackoffWaitStrategy.fallbackStrategyprotected final WaitStrategyAbstractSequencer.waitStrategyprivate final WaitStrategyProcessingSequenceBarrier.waitStrategyMethods in com.lmax.disruptor with parameters of type WaitStrategyModifier 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, WaitStrategy waitStrategy) Create a new multiple producer RingBuffer with the specified wait strategy.static <E> RingBuffer<E> RingBuffer.createSingleProducer(EventFactory<E> factory, int bufferSize, WaitStrategy waitStrategy) Create a new single producer RingBuffer with the specified wait strategy.Constructors in com.lmax.disruptor with parameters of type WaitStrategyModifierConstructorDescriptionAbstractSequencer(int bufferSize, WaitStrategy waitStrategy) Create with the specified buffer size and wait strategy.MultiProducerSequencer(int bufferSize, WaitStrategy waitStrategy) Construct a Sequencer with the selected wait strategy and buffer size.PhasedBackoffWaitStrategy(long spinTimeout, long yieldTimeout, TimeUnit units, WaitStrategy fallbackStrategy) (package private)ProcessingSequenceBarrier(Sequencer sequencer, WaitStrategy waitStrategy, Sequence cursorSequence, Sequence[] dependentSequences) SingleProducerSequencer(int bufferSize, WaitStrategy waitStrategy) Construct a Sequencer with the selected wait strategy and buffer size.(package private)SingleProducerSequencerFields(int bufferSize, WaitStrategy waitStrategy) (package private)SingleProducerSequencerPad(int bufferSize, WaitStrategy waitStrategy) -
Uses of WaitStrategy in com.lmax.disruptor.dsl
Constructors in com.lmax.disruptor.dsl with parameters of type WaitStrategyModifierConstructorDescriptionDisruptor(EventFactory<T> eventFactory, int ringBufferSize, Executor executor, ProducerType producerType, WaitStrategy waitStrategy) Deprecated.Disruptor(EventFactory<T> eventFactory, int ringBufferSize, ThreadFactory threadFactory, ProducerType producerType, WaitStrategy waitStrategy) Create a new Disruptor.
ThreadFactoryinstead of anExecutoras a the ThreadFactory is able to report errors when it is unable to construct a thread to run a producer.