Struct timely_communication::initialize::WorkerGuards

pub struct WorkerGuards<T: Send + 'static> { /* private fields */ }

Maintains JoinHandles for worker threads.

Implementations

impl<T: Send + 'static> WorkerGuards<T>

pub fn guards(&self) -> &[JoinHandle<T>]

Returns a reference to the indexed guard.

pub fn others(&self) -> &Box<dyn Any + Send>

Provides access to handles that are not worker threads.

pub fn join(self) -> Vec<Result<T, String>>

Waits on the worker threads and returns the results they produce.

Trait Implementations

impl<T: Send + 'static> Drop for WorkerGuards<T>

fn drop(&mut self)

Executes the destructor for this type.