Struct lockfree_object_pool::MutexObjectPool

pub struct MutexObjectPool<T> { /* fields omitted */ }

ObjectPool use a std::sync::Mutex over vector to secure multithread access to pull.

Example

 use lockfree_object_pool::MutexObjectPool;

 let pool = MutexObjectPool::<u32>::new(
   ||  Default::default(),
   |v| {
     *v = 0;
   }
 );
 let mut item = pool.pull();

 *item = 5;
 let work = *item * 5;

Implementations

impl<T> MutexObjectPool<T>

pub fn new<R, I>(init: I, reset: R) -> Self where
    R: Fn(&mut T) + Send + Sync + 'static,
    I: Fn() -> T + Send + Sync + 'static, 

Create an new MutexObjectPool

Arguments

• init closure to create new item
• reset closure to reset item before reusage

Example

 use lockfree_object_pool::MutexObjectPool;

 let pool = MutexObjectPool::<u32>::new(
   ||  Default::default(),
   |v| {
     *v = 0;
   }
 );

pub fn pull(&self) -> MutexReusable<'_, T>

Create a new element. When the element is dropped, it returns in the pull.

Example

 use lockfree_object_pool::MutexObjectPool;

 let pool = MutexObjectPool::<u32>::new(
   ||  Default::default(),
   |v| {
     *v = 0;
   }
 );
 let mut item = pool.pull();