Trait rayon::iter::ParallelExtend
source · pub trait ParallelExtend<T>where
T: Send,{
fn par_extend<I>(&mut self, par_iter: I)
where
I: IntoParallelIterator<Item = T>;
}
Expand description
ParallelExtend
extends an existing collection with items from a ParallelIterator
.
Examples
Implementing ParallelExtend
for your type:
use rayon::prelude::*;
use std::mem;
struct BlackHole {
mass: usize,
}
impl<T: Send> ParallelExtend<T> for BlackHole {
fn par_extend<I>(&mut self, par_iter: I)
where I: IntoParallelIterator<Item = T>
{
let par_iter = par_iter.into_par_iter();
self.mass += par_iter.count() * mem::size_of::<T>();
}
}
let mut bh = BlackHole { mass: 0 };
bh.par_extend(0i32..1000);
assert_eq!(bh.mass, 4000);
bh.par_extend(0i64..10);
assert_eq!(bh.mass, 4080);
Required Methods§
sourcefn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = T>,
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = T>,
Extends an instance of the collection with the elements drawn
from the parallel iterator par_iter
.
Examples
use rayon::prelude::*;
let mut vec = vec![];
vec.par_extend(0..5);
vec.par_extend((0..5).into_par_iter().map(|i| i * i));
assert_eq!(vec, [0, 1, 2, 3, 4, 0, 1, 4, 9, 16]);
Implementations on Foreign Types§
source§impl<T> ParallelExtend<T> for BinaryHeap<T>where
T: Ord + Send,
impl<T> ParallelExtend<T> for BinaryHeap<T>where
T: Ord + Send,
Extends a binary heap with items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = T>,
source§impl<'a, T> ParallelExtend<&'a T> for BinaryHeap<T>where
T: 'a + Copy + Ord + Send + Sync,
impl<'a, T> ParallelExtend<&'a T> for BinaryHeap<T>where
T: 'a + Copy + Ord + Send + Sync,
Extends a binary heap with copied items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = &'a T>,
source§impl<K, V> ParallelExtend<(K, V)> for BTreeMap<K, V>where
K: Ord + Send,
V: Send,
impl<K, V> ParallelExtend<(K, V)> for BTreeMap<K, V>where
K: Ord + Send,
V: Send,
Extends a B-tree map with items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = (K, V)>,
source§impl<'a, K, V> ParallelExtend<(&'a K, &'a V)> for BTreeMap<K, V>where
K: Copy + Ord + Send + Sync + 'a,
V: Copy + Send + Sync + 'a,
impl<'a, K, V> ParallelExtend<(&'a K, &'a V)> for BTreeMap<K, V>where
K: Copy + Ord + Send + Sync + 'a,
V: Copy + Send + Sync + 'a,
Extends a B-tree map with copied items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = (&'a K, &'a V)>,
source§impl<T> ParallelExtend<T> for BTreeSet<T>where
T: Ord + Send,
impl<T> ParallelExtend<T> for BTreeSet<T>where
T: Ord + Send,
Extends a B-tree set with items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = T>,
source§impl<'a, T> ParallelExtend<&'a T> for BTreeSet<T>where
T: 'a + Copy + Ord + Send + Sync,
impl<'a, T> ParallelExtend<&'a T> for BTreeSet<T>where
T: 'a + Copy + Ord + Send + Sync,
Extends a B-tree set with copied items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = &'a T>,
source§impl<K, V, S> ParallelExtend<(K, V)> for HashMap<K, V, S>where
K: Eq + Hash + Send,
V: Send,
S: BuildHasher + Send,
impl<K, V, S> ParallelExtend<(K, V)> for HashMap<K, V, S>where
K: Eq + Hash + Send,
V: Send,
S: BuildHasher + Send,
Extends a hash map with items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = (K, V)>,
source§impl<'a, K, V, S> ParallelExtend<(&'a K, &'a V)> for HashMap<K, V, S>where
K: Copy + Eq + Hash + Send + Sync + 'a,
V: Copy + Send + Sync + 'a,
S: BuildHasher + Send,
impl<'a, K, V, S> ParallelExtend<(&'a K, &'a V)> for HashMap<K, V, S>where
K: Copy + Eq + Hash + Send + Sync + 'a,
V: Copy + Send + Sync + 'a,
S: BuildHasher + Send,
Extends a hash map with copied items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = (&'a K, &'a V)>,
source§impl<T, S> ParallelExtend<T> for HashSet<T, S>where
T: Eq + Hash + Send,
S: BuildHasher + Send,
impl<T, S> ParallelExtend<T> for HashSet<T, S>where
T: Eq + Hash + Send,
S: BuildHasher + Send,
Extends a hash set with items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = T>,
source§impl<'a, T, S> ParallelExtend<&'a T> for HashSet<T, S>where
T: 'a + Copy + Eq + Hash + Send + Sync,
S: BuildHasher + Send,
impl<'a, T, S> ParallelExtend<&'a T> for HashSet<T, S>where
T: 'a + Copy + Eq + Hash + Send + Sync,
S: BuildHasher + Send,
Extends a hash set with copied items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = &'a T>,
source§impl<T> ParallelExtend<T> for LinkedList<T>where
T: Send,
impl<T> ParallelExtend<T> for LinkedList<T>where
T: Send,
Extends a linked list with items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = T>,
source§impl<'a, T> ParallelExtend<&'a T> for LinkedList<T>where
T: 'a + Copy + Send + Sync,
impl<'a, T> ParallelExtend<&'a T> for LinkedList<T>where
T: 'a + Copy + Send + Sync,
Extends a linked list with copied items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = &'a T>,
source§impl ParallelExtend<char> for String
impl ParallelExtend<char> for String
Extends a string with characters from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = char>,
source§impl<'a> ParallelExtend<&'a char> for String
impl<'a> ParallelExtend<&'a char> for String
Extends a string with copied characters from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = &'a char>,
source§impl<'a> ParallelExtend<&'a str> for String
impl<'a> ParallelExtend<&'a str> for String
Extends a string with string slices from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = &'a str>,
source§impl ParallelExtend<String> for String
impl ParallelExtend<String> for String
Extends a string with strings from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = String>,
source§impl<'a> ParallelExtend<Cow<'a, str>> for String
impl<'a> ParallelExtend<Cow<'a, str>> for String
Extends a string with string slices from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = Cow<'a, str>>,
source§impl<T> ParallelExtend<T> for VecDeque<T>where
T: Send,
impl<T> ParallelExtend<T> for VecDeque<T>where
T: Send,
Extends a deque with items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = T>,
source§impl<'a, T> ParallelExtend<&'a T> for VecDeque<T>where
T: 'a + Copy + Send + Sync,
impl<'a, T> ParallelExtend<&'a T> for VecDeque<T>where
T: 'a + Copy + Send + Sync,
Extends a deque with copied items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = &'a T>,
source§impl<T> ParallelExtend<T> for Vec<T>where
T: Send,
impl<T> ParallelExtend<T> for Vec<T>where
T: Send,
Extends a vector with items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = T>,
source§impl<'a, T> ParallelExtend<&'a T> for Vec<T>where
T: 'a + Copy + Send + Sync,
impl<'a, T> ParallelExtend<&'a T> for Vec<T>where
T: 'a + Copy + Send + Sync,
Extends a vector with copied items from a parallel iterator.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = &'a T>,
source§impl ParallelExtend<()> for ()
impl ParallelExtend<()> for ()
Collapses all unit items from a parallel iterator into one.
fn par_extend<I>(&mut self, par_iter: I)where
I: IntoParallelIterator<Item = ()>,
source§impl<A, B, FromA, FromB> ParallelExtend<(A, B)> for (FromA, FromB)where
A: Send,
B: Send,
FromA: Send + ParallelExtend<A>,
FromB: Send + ParallelExtend<B>,
impl<A, B, FromA, FromB> ParallelExtend<(A, B)> for (FromA, FromB)where
A: Send,
B: Send,
FromA: Send + ParallelExtend<A>,
FromB: Send + ParallelExtend<B>,
fn par_extend<I>(&mut self, pi: I)where
I: IntoParallelIterator<Item = (A, B)>,
source§impl<L, R, A, B> ParallelExtend<Either<L, R>> for (A, B)where
L: Send,
R: Send,
A: Send + ParallelExtend<L>,
B: Send + ParallelExtend<R>,
impl<L, R, A, B> ParallelExtend<Either<L, R>> for (A, B)where
L: Send,
R: Send,
A: Send + ParallelExtend<L>,
B: Send + ParallelExtend<R>,
fn par_extend<I>(&mut self, pi: I)where
I: IntoParallelIterator<Item = Either<L, R>>,
Implementors§
impl<L, R, T> ParallelExtend<T> for Either<L, R>where
L: ParallelExtend<T>,
R: ParallelExtend<T>,
T: Send,
Either<L, R>
can be extended if both L
and R
are parallel extendable.