Struct MutexObjectPool

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

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();

pub fn pull_owned(self: &Arc<Self>) -> MutexOwnedReusable<T>

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

Example

 use lockfree_object_pool::MutexObjectPool;
 use std::sync::Arc;

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