Struct ParallelForEachMut 

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

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

 use parallel_task::{for_each_mut::ParallelForEachMutIter, prelude::*};
 
 let mut test = 0;
 let target = 100;
 (0..=target).collect::<Vec<i32>>().
 parallel_iter().for_each_mut(|v| { test += v;});
 assert_eq!(test, (target * (target + 1)/2));

Fields

iter: TaskQueue<I, V>

f: F

num_threads: usize

v: PhantomData<V>

Implementations

impl<I, V, F> ParallelForEachMut<V, F, I>

where I: AtomicIterator<AtomicItem = V> + Send + Sized, F: FnMut(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)