Sha256: 019e9379ccab57a299ab5b5a2c0efc7561b77a715a5afe8f797c7e8330c6206c
Contents?: true
Size: 687 Bytes
Versions: 35
Compression:
Stored size: 687 Bytes
Contents
use rayon::prelude::*;
use alloc::collections::LinkedList;
use crate::vec::Vec;
pub mod map;
pub mod set;
// This form of intermediate collection is also how Rayon collects `HashMap`.
// Note that the order will also be preserved!
fn collect<I: IntoParallelIterator>(iter: I) -> LinkedList<Vec<I::Item>> {
iter.into_par_iter()
.fold(Vec::new, |mut vec, elem| {
vec.push(elem);
vec
})
.map(|vec| {
let mut list = LinkedList::new();
list.push_back(vec);
list
})
.reduce(LinkedList::new, |mut list1, mut list2| {
list1.append(&mut list2);
list1
})
}
Version data entries
35 entries across 30 versions & 1 rubygems