Struct lockfree_object_pool::LinearObjectPool

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

ObjectPool use a lockfree vector to secure multithread access to pull.

The lockfree vector is implemented as linked list.

Example

 use lockfree_object_pool::LinearObjectPool;

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

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

Implementations

impl<T> LinearObjectPool<T>

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

Create an new LinearObjectPool

Arguments

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

Example

 use lockfree_object_pool::LinearObjectPool;

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

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

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

Example

 use lockfree_object_pool::LinearObjectPool;

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