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 class
Blocking strategy that uses a lock and condition variable forEventProcessor
s waiting on a barrier.final class
Busy Spin strategy that uses a busy spin loop forEventProcessor
s waiting on a barrier.final class
Variation of theBlockingWaitStrategy
that attempts to elide conditional wake-ups when the lock is uncontended.class
Variation of theTimeoutBlockingWaitStrategy
that attempts to elide conditional wake-ups when the lock is uncontended.final class
Phased wait strategy for waitingEventProcessor
s on a barrier.final class
Sleeping 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 theEventProcessor
s are waiting on a barrier.class
final class
Yielding strategy that uses a Thread.yield() forEventProcessor
s waiting on a barrier after an initially spinning.Fields in com.lmax.disruptor declared as WaitStrategyModifier and TypeFieldDescriptionprivate final WaitStrategy
PhasedBackoffWaitStrategy.fallbackStrategy
protected final WaitStrategy
AbstractSequencer.waitStrategy
private final WaitStrategy
ProcessingSequenceBarrier.waitStrategy
Methods 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.
ThreadFactory
instead of anExecutor
as a the ThreadFactory is able to report errors when it is unable to construct a thread to run a producer.