Struct Parallel 

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

A cohesive set of thread-local values of a given type.

Mutable references can be fetched if T: Default via Parallel::scope.

Implementations

impl<T> Parallel<T>

where T: Send,

pub fn iter_mut(&mut self) -> impl Iterator<Item = &mut T>

Gets a mutable iterator over all of the per-thread queues.

pub fn clear(&mut self)

Clears all of the stored thread local values.

pub fn scope_or<R>( &self, create: impl FnOnce() -> T, f: impl FnOnce(&mut T) -> R, ) -> R

Retrieves the thread-local value for the current thread and runs f on it.

If there is no thread-local value, it will be initialized to the result of create.

pub fn borrow_local_mut_or(&self, create: impl FnOnce() -> T) -> impl DerefMut

Mutably borrows the thread-local value.

If there is no thread-local value, it will be initialized to the result of create.

impl<T> Parallel<T>

where T: Default + Send,

pub fn scope<R>(&self, f: impl FnOnce(&mut T) -> R) -> R

Retrieves the thread-local value for the current thread and runs f on it.

If there is no thread-local value, it will be initialized to its default.

pub fn borrow_local_mut(&self) -> impl DerefMut

Mutably borrows the thread-local value.

If there is no thread-local value, it will be initialized to its default.

impl<T, I> Parallel<I>

where I: IntoIterator<Item = T> + Default + Send + 'static,

pub fn drain(&mut self) -> impl Iterator<Item = T>

Drains all enqueued items from all threads and returns an iterator over them.

Unlike Vec::drain, this will piecemeal remove chunks of the data stored. If iteration is terminated part way, the rest of the enqueued items in the same chunk will be dropped, and the rest of the undrained elements will remain.

The ordering is not guaranteed.

impl<T> Parallel<Vec<T>>

where T: Send,

pub fn drain_into(&mut self, out: &mut Vec<T>)

Collect all enqueued items from all threads and appends them to the end of a single Vec.

The ordering is not guaranteed.

Trait Implementations

impl<T> Default for Parallel<T>

where T: Send,

fn default() -> Parallel<T>

Returns the “default value” for a type.