Top Description Classes
[default module]

Package reactor.util.concurrent

Annotations
@NonNullApi
Imports
reactor.util.annotation.NonNullApi
Queue suppliers and utilities Used for operational serialization (serializing threads) or buffering (asynchronous boundary).
Author
Stephane Maldini

Class Summary

Modifier and TypeClass and Description
pack-priv class
MpscLinkedQueue<
the contained value type
E>

A multi-producer single consumer unbounded queue.

public class
Queues

Queue utilities and suppliers for 1-producer/1-consumer ready queues adapted for various given capacities.

pack-priv class
SpscArrayQueue<
the value type
T>

A bounded, array backed, single-producer single-consumer queue.

pack-priv class
SpscArrayQueueCold<T>

pack-priv class
SpscArrayQueueConsumer<T>

pack-priv class
SpscArrayQueueP1<T>

pack-priv class
SpscArrayQueueP2<T>

pack-priv class
SpscArrayQueueP3<T>

pack-priv class
SpscArrayQueueProducer<T>

pack-priv class
SpscLinkedArrayQueue<
the value type
T>

An unbounded, array-backed single-producer, single-consumer queue with a fixed link size.