Struct ParallelVec 

pub struct ParallelVec<'a, T: Sync> { /* private fields */ }

A parallel iterator that executes operations in parallel

Implementations

impl<'a, T: Sync> ParallelVec<'a, T>

pub fn new(data: &'a [T]) -> Self

Create a new parallel vector iterator

pub fn map<R, F>(self, f: F) -> ParallelMap<'a, T, R, F>

where R: Send, F: Fn(&T) -> R + Send + Sync,

Map operation in parallel

pub fn filter<F>(self, f: F) -> ParallelFilter<'a, T, F>

where F: Fn(&T) -> bool + Send + Sync,

Filter operation in parallel

pub fn for_each<F>(self, f: F)

where F: Fn(&T) + Send + Sync,

For each operation in parallel

pub fn sum(self) -> T

where T: Clone + Send + Sum,

Sum operation in parallel

pub fn reduce<F>(self, f: F) -> Option<T>

where T: Clone + Send, F: Fn(T, T) -> T + Send + Sync,

Reduce operation in parallel

pub fn collect(self) -> Vec<&'a T>

Collect into a Vec