Struct ParallelMapper 

pub struct ParallelMapper<Input, Output, Map>
where
    Input: Send + 'static,
    Output: Send + 'static,
    Map: Fn(Input) -> Output + Send + Sync + 'static,
{ /* private fields */ }

Implementations

impl<Input, Output, Map> ParallelMapper<Input, Output, Map>

where Input: Send + 'static, Output: Send + 'static, Map: Fn(Input) -> Output + Send + Sync + 'static,

pub fn new(max_workers: u32, map: Map) -> Self

pub fn concurrency(&self) -> u32

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

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

Pops and returns result if any

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

Pops and returns all results if any

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

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

Processes the provided inputs in parallel.

Ordering

The order of outputs is not guaranteed to match the input order. Outputs are returned in completion order.

pub fn wait(&self)

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

Trait Implementations

impl<Input, Output, Map> Drop for ParallelMapper<Input, Output, Map>

where Input: Send + 'static, Output: Send + 'static, Map: Fn(Input) -> Output + Send + Sync + 'static,

fn drop(&mut self)

Executes the destructor for this type.