Package reactor.util.concurrent

Queue suppliers and implementation of the bounded hardware friendly RingBuffer.

See: Description

Interface Summary

Interface	Description
Sequence	Concurrent sequence class used for tracking the progress of the ring buffer and event processors.

Class Summary

Class	Description
QueueSupplier<T>	Provide a queue adapted for a given capacity
RingBuffer<E>	Ring based store of reusable entries containing the data representing an event being exchanged between event producer and ringbuffer consumers.
RingBufferReader	Used for Gating ringbuffer consumers on a cursor sequence and optional dependent ringbuffer consumer(s), using the given WaitStrategy.
WaitStrategy	Strategy employed to wait for specific LongSupplier values with various spinning strategies.

Package reactor.util.concurrent Description

Queue suppliers and implementation of the bounded hardware friendly RingBuffer. Used for operational serialization (serializing threads) or buffering (asynchronous boundary).