Struct timely::communication::initialize::WorkerGuards

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

Maintains JoinHandles for worker threads.

Implementations

impl<T> WorkerGuards<T>

where T: Send + 'static,

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> Drop for WorkerGuards<T>

where T: Send + 'static,

fn drop(&mut self)

Executes the destructor for this type.