Struct CollectiveWork 

pub struct CollectiveWork<T, E = WorkError> { /* private fields */ }

Asynchronous collective completion handle. Dropping it detaches the host worker but does not cancel or reorder an already submitted collective.

Implementations

impl<T: Send + 'static, E: From<WorkError> + Send + 'static> CollectiveWork<T, E>

pub fn spawn( name: &'static str, task: impl FnOnce() -> Result<T, E> + Send + 'static, ) -> Result<Self, E>

pub fn is_complete(&self) -> bool

pub fn wait_for(&self, timeout: Duration) -> Result<bool, E>

pub fn wait(self) -> Result<T, E>

Trait Implementations

impl<T: Debug, E: Debug> Debug for CollectiveWork<T, E>

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

Formats the value using the given formatter.