Struct lazy_async_pool::Pool

pub struct Pool<T: Send + 'static, F: Fn() -> U, U: Future<Output = Result<T, E>> + Unpin, E>(_);

Lazy Asyncronous Object Pool

Implementations

impl<T, F, U, E> Pool<T, F, U, E> where
    T: Send,
    F: Fn() -> U,
    U: Future<Output = Result<T, E>> + Unpin, 

pub fn new(cap: usize, gen: F) -> Self

Generates a new pool.

Arguments

• cap - Maximum number of objects to generate.
  • Use 0 to make it unbounded.
  • The timeout feature can cause it to go past this limit, but extra resources will be dropped when released.

pub async fn get(self) -> Result<PoolGuard<T, F, U, E>, E>

Obtain an item from the pool. If the pool is exhausted and not at capacity, generates a new item. If the pool is exhausted and at capacity, wait for a new item to be available.

pub fn len(&self) -> usize

Number of items available in the pool.

pub fn add(&self, item: T) -> Result<(), TrySendError<T>>

Manually add a new item to the pool.

• Does not count towards the cap.

Trait Implementations

impl<T, F, U, E> Clone for Pool<T, F, U, E> where
    T: Send,
    F: Fn() -> U,
    U: Future<Output = Result<T, E>> + Unpin, 

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.