Struct TaskFuture 

pub struct TaskFuture { /* private fields */ }

A future that tracks completion of submitted tasks

TaskFuture provides both blocking and non-blocking ways to wait for task completion. Tasks can be checked for completion, waited on indefinitely, or waited on with a timeout.

TaskFuture is cheaply cloneable. However, it captures the thread handle of the thread that created it.

If sharing the future with other threads, is_complete() is safe to call from anywhere.

Important: wait() and wait_timeout() must be called from the same thread that created the TaskFuture. Calling these methods from a different thread will panic in debug builds and may cause the calling thread to hang indefinitely in release builds.

Implementations

impl TaskFuture

pub fn is_complete(&self) -> bool

Check if all tasks are complete without blocking

Returns true if all tasks have finished execution. This is a non-blocking operation using an atomic load.

pub fn wait(&self)

Wait for all tasks to complete.

First checks completion with an atomic load; if incomplete, parks the thread.

Warning: This method must be called from the same thread that created this TaskFuture.

pub fn wait_timeout(&self, timeout: Duration) -> bool

Wait for all tasks to complete with a timeout.

First checks completion with an atomic load; if incomplete, parks the thread. Returns true if all tasks completed within the timeout, false if the timeout was reached first.

Warning: This method must be called from the same thread that created this TaskFuture.

Trait Implementations

impl Clone for TaskFuture

fn clone(&self) -> TaskFuture

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.