Struct ThreadGroup 

pub struct ThreadGroup<T> { /* private fields */ }

ThreadGroup is allows spawning several threads and waiting for their completion through the specialized methods.

Implementations

impl<T: Send + Sync + 'static> ThreadGroup<T>

pub fn new() -> ThreadGroup<T>

ThreadGroup::new creates a new thread group

pub fn with_id(id: String) -> ThreadGroup<T>

ThreadGroup::with_id creates a new thread group with a specific id (String)

pub fn spawn<F: FnOnce() -> T + Send + 'static>( &mut self, func: F, ) -> Result<()>

ThreadGroup::spawn spawns a thread

pub fn join(&mut self) -> Result<T>

ThreadGroup::join waits for the first thread to join in blocking fashion, returning the result of that threads FnOnce

pub fn results(&mut self) -> Vec<Result<T>>

ThreadGroup::results waits for the all threads to join in blocking fashion, returning all their results at once as a Vec<Result<T>>

pub fn as_far_as_ok(&mut self) -> Vec<T>

ThreadGroup::as_far_as_ok waits for the all threads to join in blocking fashion, returning all the OK results at once as a Vec<T> but ignoring all errors.

pub fn all_ok(&mut self) -> Result<Vec<T>>

ThreadGroup::all_ok waits for the all threads to join in blocking fashion, returning all the OK results at once as a Vec<T> if there are no errors.

pub fn errors(&self) -> BTreeMap<String, Error>

ThreadGroup::errors returns a BTreeMap<String, Error> of errors whose keys are thread ids that panicked.

Trait Implementations

impl<T: Send + Sync + 'static> Default for ThreadGroup<T>

fn default() -> ThreadGroup<T>

Returns the “default value” for a type.

impl<T> Display for ThreadGroup<T>

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

Formats the value using the given formatter.