Package reactor.pool

@NullMarked package reactor.pool

API for reactive pooling of arbitrary objects using Reactor's Mono.

Author:

Simon Baslé

Related Packages

Package	Description
reactor.pool.decorators
reactor.pool.introspection

Class	Description
AllocationStrategy	A strategy guiding the Pool on whether or not it is possible to invoke the resource allocator.
DefaultPoolConfig<POOLABLE>	A default PoolConfig that can be extended to bear more configuration options with access to a copy constructor for the basic options.
InstrumentedPool<POOLABLE>	An InstrumentedPool is a Pool that exposes a few additional methods around metrics.
InstrumentedPool.PoolMetrics	An object that can be used to get live information about a Pool, suitable for gauge metrics.
Pool<POOLABLE>	A reactive pool of objects.
PoolAcquirePendingLimitException	A RuntimeException that rejects a Pool.acquire() operation due to too many similar operations being in a pending state waiting for resources to be released.
PoolAcquireTimeoutException	A specialized TimeoutException that denotes that a Pool.acquire(Duration) has timed out.
PoolBuilder<T,CONF extends PoolConfig<T>>	A builder for Pool implementations, which tuning methods map to a PoolConfig subclass, CONF.
PoolConfig<POOLABLE>	A representation of the common configuration options of a Pool.
PooledRef<POOLABLE>	An abstraction over an object in a Pool, which holds the underlying POOLABLE object and allows one to manually PooledRef.release() it to the pool or PooledRef.invalidate() it.
PooledRefMetadata	Metadata about a PooledRef, which includes monotonic metrics like its age (PooledRefMetadata.lifeTime()), number of times it was reused (PooledRefMetadata.acquireCount()), as well as contextually changing metrics like the duration for which it has been idle in a pool (PooledRefMetadata.idleTime()).
PoolMetricsRecorder	An interface representing ways for Pool to collect instrumentation data.
PoolShutdownException	A RuntimeException that denotes that a Pool has been disposed.
SimpleDequePool<POOLABLE>	The SimpleDequePool is based on Deque for idle resources and pending Pool.acquire() Monos, allowing both to be ordered either LIFO or FIFO.