Struct VecParallelSink 

pub struct VecParallelSink<T>
where
    T: Send,
{ /* private fields */ }

A parallel sink towards a Vec. This struct is consumed by the finalize() method on FromExactParallelSink.

You most likely won’t need to interact with this struct directly, as it implements the ExactParallelSink trait, but it is nonetheless public as it is an associated type of FromExactParallelSink for Vec and similar collections.

let vec: Vec<_> = (1..=10)
    .into_par_iter()
    .with_thread_pool(&mut thread_pool)
    .collect();
assert_eq!(vec, vec![1, 2, 3, 4, 5, 6, 7, 8, 9, 10]);

The element type must be Send, so the following example doesn’t compile.

use std::rc::Rc;

let vec: Vec<Rc<_>> = (1..=10)
    .into_par_iter()
    .map(Rc::new)
    .with_thread_pool(&mut thread_pool)
    .collect();

Trait Implementations

impl<T> ExactParallelSink for VecParallelSink<T>

where T: Send,

const NEEDS_CLEANUP: bool

Set to false if the skip function is guaranteed to be a noop.

type Item = T

The type of items that this parallel sink collects.

fn new(len: usize) -> VecParallelSink<T>

Creates a new sink able to collect the given number of items.

unsafe fn push_item( &self, index: usize, item: <VecParallelSink<T> as ExactParallelSink>::Item, )

Pushes the given item at the given index of this sink.

unsafe fn skip_item_range(&self, range: Range<usize>)

Indicates that the items in the given range won’t be pushed.

unsafe fn cancel(self)

Cancel and cleanup this sink.