Struct ElasticObjectPool 

pub struct ElasticObjectPool<T: Poolable> { /* private fields */ }

An elastic object pool.

Pools are configured with a minimum and maximum size, and allocate the minimum number of items up front. When an item is requested and the pool is empty, but hasn’t yet reached its maximum size, it will allocate the item on demand.

After a grace period without growth, a background task shrinks idle capacity toward the minimum capacity. Shrinking removes a fraction of the excess idle items each interval, and returned items above the minimum are dropped immediately while shrinking is active. A new on-demand allocation disables shrinking for another grace period so nearby bursts can reuse the existing capacity.

Missing

• Configurability for the shrinking frequency, grace period, and batch fraction.

Implementations

impl<T> ElasticObjectPool<T>

where T: Poolable + 'static, T::Data: Default,

pub fn with_capacity<S>( pool_name: S, min_capacity: usize, max_capacity: usize, ) -> (Self, impl Future<Output = ()>)

where S: AsRef<str>,

Creates a new ElasticObjectPool with the given minimum and maximum capacity.

impl<T> ElasticObjectPool<T>

where T: Poolable + 'static,

pub fn with_builder<S, B>( pool_name: S, min_capacity: usize, max_capacity: usize, builder: B, ) -> (Self, impl Future<Output = ()>)

where S: AsRef<str>, B: Fn() -> T::Data + Send + Sync + 'static,

Creates a new ElasticObjectPool with the given minimum and maximum capacity and item builder.

builder is called to construct each item.

Trait Implementations

impl<T: Poolable> Clone for ElasticObjectPool<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> ObjectPool for ElasticObjectPool<T>

where T: Poolable + Send + Unpin + 'static,

type Item = T

The pooled value.

type AcquireFuture = ElasticAcquireFuture<T>

Type of future returned by acquire.

fn acquire(&self) -> Self::AcquireFuture

Acquires an item from the object pool.