Struct easy_parallel::Parallel

#[must_use]pub struct Parallel<'a> { /* fields omitted */ }

A builder that runs closures in parallel.

Implementations

impl<'a> Parallel<'a>

pub fn new() -> Parallel<'a>

Creates a builder for running closures in parallel.

Examples

use easy_parallel::Parallel;

let p = Parallel::new();

pub fn add<F>(self, f: F) -> Parallel<'a> where
    F: FnOnce() + Send + 'a, 

Adds a closure to the list.

Examples

use easy_parallel::Parallel;

Parallel::new()
    .add(|| println!("hello from a thread"))
    .run();

pub fn each<T, I, F>(self, iter: I, f: F) -> Parallel<'a> where
    I: IntoIterator<Item = T>,
    F: FnOnce(T) + Clone + Send + 'a,
    T: Send + 'a, 

Adds a cloned closure for each item in an iterator.

Each clone of the closure takes an item as an argument.

Examples

use easy_parallel::Parallel;

Parallel::new()
    .each(0..5, |i| println!("thread #{}", i))
    .run();

pub fn run(self)

Spawns a thread for each closure and waits from them to complete.

If a closure panics, panicking will resume in the main thread after all threads are joined.

Examples

use easy_parallel::Parallel;

Parallel::new()
    .add(|| println!("thread #1"))
    .add(|| println!("thread #2"))
    .run();

Trait Implementations

impl<'_> Debug for Parallel<'_>

fn fmt(&self, f: &mut Formatter) -> Result

Formats the value using the given formatter.

impl<'a> Default for Parallel<'a>

fn default() -> Parallel<'a>

Returns the "default value" for a type.