Struct FixedSizeObjectPool 

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

A fixed-size object pool.

All items for this object pool are created up front, and when the object pool is empty, calls to acquire will block until an item is returned to the pool.

Metrics

• object_pool.acquired{pool_name="<pool_name>"} - total count of the number of objects acquired from the pool (counter)
• object_pool.released{pool_name="<pool_name>"} - total count of the number of objects released back to the pool (counter)
• object_pool.in_use{pool_name="<pool_name>"} - number of objects from the pool that are currently in use (gauge)

Implementations

impl<T: Poolable> FixedSizeObjectPool<T>

where T::Data: Default,

pub fn with_capacity<S>(pool_name: S, capacity: usize) -> Self

where S: Into<String>,

Creates a new FixedSizeObjectPool with the given capacity.

Metrics are emitted for the pool with a tag (pool_name) that is set to the value of the given pool name.

impl<T: Poolable> FixedSizeObjectPool<T>

pub fn with_builder<S, B>(pool_name: S, capacity: usize, builder: B) -> Self

where S: Into<String>, B: Fn() -> T::Data,

Creates a new FixedSizeObjectPool with the given capacity and item builder.

builder is called to construct each item.

Metrics are emitted for the pool with a tag (pool_name) that is set to the value of the given pool name.

Trait Implementations

impl<T: Poolable> Clone for FixedSizeObjectPool<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 FixedSizeObjectPool<T>

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

type Item = T

The pooled value.

type AcquireFuture = FixedSizeAcquireFuture<T>

Type of future returned by acquire.

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

Acquires an item from the object pool.