Struct ParallelForEach 

pub struct ParallelForEach<V, F, I>
where
    I: AtomicIterator<AtomicItem = V> + Send + Sized,
    F: Fn(V),
    V: Send,
{
    pub iter: TaskQueue<I, V>,
    pub f: Pin<Box<F>>,
    pub num_threads: usize,
    pub v: PhantomData<V>,
}

ParallelForEach is a structure type that captures the information necessary to run the values within the Iterator in parallel Its the result of parallel_task that can be run on any Iterator implementing type.

use parallel_task::prelude::*;
 
(0..100_000).collect::<Vec<i32>>().parallel_iter().for_each(|val|{ print!(" {}",val);});
assert_eq!(1,1)

Fields

iter: TaskQueue<I, V>

f: Pin<Box<F>>

num_threads: usize

v: PhantomData<V>

Implementations

impl<I, V, F> ParallelForEach<V, F, I>

where I: AtomicIterator<AtomicItem = V> + Send + Sized, F: Fn(V) + Send, V: Send,

pub fn new(iter: I, f: F) -> Self

pub fn threads(self, nthreads: usize) -> Self

Set the thread pool size for running the parallel tasker

pub fn run(self)