reactor.util.concurrent

Class QueueSupplier<T>

java.lang.Object

reactor.util.concurrent.QueueSupplier<T>

Type Parameters:

T - the queue element type

All Implemented Interfaces:

Supplier<Queue<T>>

public final class QueueSupplier<T>
extends Object
implements Supplier<Queue<T>>

Provide a 1-producer/1-consumer ready queue adapted for a given capacity.

Field Summary

Fields

Modifier and Type	Field and Description
static int	SMALL_BUFFER_SIZE A small default of available slots in a given container, compromise between intensive pipelines, small subscribers numbers and memory use.
static int	XS_BUFFER_SIZE An allocation friendly default of available slots in a given container, e.g.

Method Summary

Modifier and Type	Method and Description
static int	ceilingNextPowerOfTwo(int x) Calculate the next power of 2, greater than or equal to x.
Queue<T>	get()
static <T> Supplier<Queue<T>>	get(int batchSize)
static boolean	isPowerOfTwo(int x)
static <T> Supplier<Queue<T>>	one()
static <T> Supplier<Queue<T>>	small()
static <T> Supplier<Queue<T>>	unbounded()
static <T> Supplier<Queue<T>>	unbounded(int linkSize) Returns an unbounded, linked-array-based Queue.
static <T> Supplier<Queue<T>>	xs()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

XS_BUFFER_SIZE

public static final int XS_BUFFER_SIZE

An allocation friendly default of available slots in a given container, e.g. slow publishers and or fast/few subscribers

SMALL_BUFFER_SIZE

public static final int SMALL_BUFFER_SIZE

A small default of available slots in a given container, compromise between intensive pipelines, small subscribers numbers and memory use.

Method Detail

ceilingNextPowerOfTwo

public static int ceilingNextPowerOfTwo(int x)

Calculate the next power of 2, greater than or equal to x.

From Hacker's Delight, Chapter 3, Harry S. Warren Jr.

Parameters:

x - Value to round up

Returns:

The next power of 2 from x inclusive

get

public static <T> Supplier<Queue<T>> get(int batchSize)

Type Parameters:

T - the reified Queue generic type

Parameters:

batchSize - the bounded or unbounded (int.max) queue size

Returns:

an unbounded or bounded Queue Supplier

isPowerOfTwo

public static boolean isPowerOfTwo(int x)

Parameters:

x - the int to test

Returns:

true if x is a power of 2

one

public static <T> Supplier<Queue<T>> one()

Type Parameters:

T - the reified Queue generic type

Returns:

a bounded Queue Supplier

small

public static <T> Supplier<Queue<T>> small()

Type Parameters:

T - the reified Queue generic type

Returns:

a bounded Queue Supplier

unbounded

public static <T> Supplier<Queue<T>> unbounded()

Type Parameters:

T - the reified Queue generic type

Returns:

an unbounded Queue Supplier

unbounded

public static <T> Supplier<Queue<T>> unbounded(int linkSize)

Returns an unbounded, linked-array-based Queue. Integer.max sized link will return the default SMALL_BUFFER_SIZE size.

Type Parameters:

T - the reified Queue generic type

Parameters:

linkSize - the link size

Returns:

an unbounded Queue Supplier

xs

public static <T> Supplier<Queue<T>> xs()

Type Parameters:

T - the reified Queue generic type

Returns:

a bounded Queue Supplier

get

public Queue<T> get()

Specified by:

get in interface Supplier<Queue<T>>