eta_obj_pool 1.1.0

Thread safe object pool
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19

use std::sync::Arc;
use crate::errors::PoolError;
pub trait PoolElementProxy<ElementType>
where Self: Drop
{
    type Pool: Pool<ElementType, Proxy = Self>;
    fn new(element: ElementType, pool: Arc<Self::Pool>) -> Self;
    fn get(&self) -> &ElementType;
    fn get_mut(&mut self) -> &mut ElementType;
    fn forget(self);
}

pub trait Pool<ElementType> {
    type Proxy: PoolElementProxy<ElementType>;
    fn acquire(self_ref: Arc<Self>) -> Option<Self::Proxy>;
    fn push_element(&self, element: ElementType) -> PoolError<()>;
    fn push_elements(&self, elements: Vec<ElementType>) -> PoolError<()>;
    fn len(&self) -> usize;
}