Struct DynParallelMapper 

pub struct DynParallelMapper<Input, Output>
where
    Input: Send + 'static,
    Output: Send + 'static,
{ /* private fields */ }

Implementations

impl<Input, Output> DynParallelMapper<Input, Output>

where Input: Send + 'static, Output: Send + 'static,

pub fn new( max_workers: u32, map: Box<dyn Fn(Input) -> Output + Send + Sync>, ) -> Self

pub fn concurrency(&self) -> u32

pub fn process_all<I>(&mut self, inputs: I) -> Vec<Output>

where I: IntoIterator, I::Item: Borrow<Input>, Input: Clone,

pub fn push(&mut self, input: Input)

pub fn pop(&mut self) -> Option<Output>

pub fn pop_all(&mut self) -> Vec<Output>

pub fn wait(&self)

pub fn finish(&mut self) -> Vec<Output>