Struct mithril_common::resource_pool::ResourcePool

pub struct ResourcePool<T: Reset + Send + Sync> { /* private fields */ }

Resource pool implementation (FIFO)

Implementations

impl<T: Reset + Send + Sync> ResourcePool<T>

pub fn new(pool_size: usize, resources: Vec<T>) -> Self

Create a new resource pool

pub fn acquire_resource( &self, timeout: Duration, ) -> StdResult<ResourcePoolItem<'_, T>>

Acquire a resource from the pool with a timeout

pub fn give_back_resource( &self, resource: T, discriminant: u64, ) -> StdResult<()>

Give back a resource to the pool A resource is given back to the pool only if the discriminant matches and if the pool is not already full

pub fn give_back_resource_pool_item( &self, resource_pool_item: ResourcePoolItem<'_, T>, ) -> StdResult<()>

Give back a resource pool item to the pool If the resource pool item has not been taken yet, the resource will be given back If the resource pool item has been taken, nothing will happen

pub fn clear(&self)

Clear the pool

pub fn discriminant(&self) -> StdResult<u64>

Get the discriminant of the resource pool item

pub fn set_discriminant(&self, discriminant: u64) -> StdResult<()>

Set the discriminant of the resource pool item

pub fn count(&self) -> StdResult<usize>

Count the resources in the pool

pub fn size(&self) -> usize

Size of the resource pool