Struct MkAsyncPool 

pub struct MkAsyncPool<T> { /* private fields */ }

Async-aware object pool with backpressure support.

Implementations

impl<T> MkAsyncPool<T>

pub fn new(capacity: usize, backpressure: MkBackpressure) -> Self

Create a new async pool.

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

Add an item to the pool.

pub async fn acquire(&self) -> Option<MkPoolGuard<T>>

Acquire an item from the pool.

pub fn try_acquire(&self) -> Option<MkPoolGuard<T>>

Try to acquire an item without waiting.

pub fn capacity(&self) -> usize

Get the pool capacity.

pub fn available(&self) -> usize

Get the number of available items.

Trait Implementations

impl<T> Clone for MkAsyncPool<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.