Queues (reactor-3)

java.lang.Object
- reactor.util.concurrent.Queues

```
public final class Queues
extends java.lang.Object
```
Queue utilities and suppliers for 1-producer/1-consumer ready queues adapted for various given capacities.

字段概要

字段
限定符和类型	字段和说明
`static int`	`CAPACITY_UNSURE`
`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. slow publishers and or fast/few subscribers

方法概要

所有方法静态方法具体方法
限定符和类型	方法和说明
`static int`	`capacity(java.util.Queue q)` Return the capacity of a given `Queue` in a best effort fashion.
`static int`	`ceilingNextPowerOfTwo(int x)` Calculate the next power of 2, greater than or equal to x.
`static <T> java.util.function.Supplier<java.util.Queue<T>>`	`empty()` A `Supplier` for an empty immutable `Queue`, to be used as a placeholder in methods that require a Queue when one doesn't expect to store any data in said Queue.
`static <T> java.util.function.Supplier<java.util.Queue<T>>`	`get(int batchSize)`
`static boolean`	`isPowerOfTwo(int x)`
`static <T> java.util.function.Supplier<java.util.Queue<T>>`	`one()`
`static <T> java.util.function.Supplier<java.util.Queue<T>>`	`small()`
`static <T> java.util.function.Supplier<java.util.Queue<T>>`	`unbounded()`
`static <T> java.util.function.Supplier<java.util.Queue<T>>`	`unbounded(int linkSize)` Returns an unbounded, linked-array-based Queue.
`static <T> java.util.function.Supplier<java.util.Queue<T>>`	`unboundedMultiproducer()` Returns an unbounded queue suitable for multi-producer/single-consumer (MPSC) scenarios.
`static <T> java.util.function.Supplier<java.util.Queue<T>>`	`xs()`

从类继承的方法 java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- 字段详细资料
  - CAPACITY_UNSURE
```
public static final int CAPACITY_UNSURE
```
    另请参阅:
    
    常量字段值
  - 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.
- 方法详细资料
  - capacity
```
public static final int capacity(java.util.Queue q)
```
    Return the capacity of a given Queue in a best effort fashion. Queues that are known to be unbounded will return Integer.MAX_VALUE and queues that have a known bounded capacity will return that capacity. For other Queue implementations not recognized by this method or not providing this kind of information, CAPACITY_UNSURE (Integer.MIN_VALUE) is returned.
    
    参数:
    
    q - the Queue to try to get a capacity for
    
    返回:
    
    the capacity of the queue, if discoverable with confidence, or CAPACITY_UNSURE negative constant.
  - 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.
    
    参数:
    
    x - Value to round up
    
    返回:
    
    The next power of 2 from x inclusive
  - get
```
public static <T> java.util.function.Supplier<java.util.Queue<T>> get(int batchSize)
```
    类型参数:
    
    T - the reified Queue generic type
    
    参数:
    
    batchSize - the bounded or unbounded (int.max) queue size
    
    返回:
    
    an unbounded or bounded Queue Supplier
  - isPowerOfTwo
```
public static boolean isPowerOfTwo(int x)
```
    参数:
    
    x - the int to test
    
    返回:
    
    true if x is a power of 2
  - empty
```
public static <T> java.util.function.Supplier<java.util.Queue<T>> empty()
```
    A Supplier for an empty immutable Queue, to be used as a placeholder in methods that require a Queue when one doesn't expect to store any data in said Queue.
    
    类型参数:
    
    T - the reified Queue generic type
    
    返回:
    
    an immutable empty Queue Supplier
  - one
```
public static <T> java.util.function.Supplier<java.util.Queue<T>> one()
```
    类型参数:
    
    T - the reified Queue generic type
    
    返回:
    
    a bounded Queue Supplier
  - small
```
public static <T> java.util.function.Supplier<java.util.Queue<T>> small()
```
    类型参数:
    
    T - the reified Queue generic type
    
    返回:
    
    a bounded Queue Supplier
  - unbounded
```
public static <T> java.util.function.Supplier<java.util.Queue<T>> unbounded()
```
    类型参数:
    
    T - the reified Queue generic type
    
    返回:
    
    an unbounded Queue Supplier
  - unbounded
```
public static <T> java.util.function.Supplier<java.util.Queue<T>> unbounded(int linkSize)
```
    Returns an unbounded, linked-array-based Queue. Integer.max sized link will return the default SMALL_BUFFER_SIZE size.
    
    类型参数:
    
    T - the reified Queue generic type
    
    参数:
    
    linkSize - the link size
    
    返回:
    
    an unbounded Queue Supplier
  - xs
```
public static <T> java.util.function.Supplier<java.util.Queue<T>> xs()
```
    类型参数:
    
    T - the reified Queue generic type
    
    返回:
    
    a bounded Queue Supplier
  - unboundedMultiproducer
```
public static <T> java.util.function.Supplier<java.util.Queue<T>> unboundedMultiproducer()
```
    Returns an unbounded queue suitable for multi-producer/single-consumer (MPSC) scenarios.
    
    类型参数:
    
    T - the reified Queue generic type
    
    返回:
    
    an unbounded MPSC Queue Supplier

类 Queues

字段概要

方法概要

从类继承的方法 java.lang.Object

字段详细资料

CAPACITY_UNSURE

XS_BUFFER_SIZE

SMALL_BUFFER_SIZE

方法详细资料

capacity

ceilingNextPowerOfTwo

get

isPowerOfTwo

empty

one

small

unbounded

unbounded

xs

unboundedMultiproducer