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, with efficient condition variable notification. Tasks can be checked for completion, waited on indefinitely, or waited on with a timeout.

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 atomic loads.

pub fn wait(self)

Wait for all tasks to complete

This method blocks the current thread until all tasks finish. It uses efficient condition variable notification to minimize CPU usage while waiting.

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

Wait for all tasks to complete with a timeout

Returns true if all tasks completed within the timeout, false if the timeout was reached first.

pub fn remaining_count(&self) -> usize

Get the approximate number of remaining incomplete tasks

This provides a way to monitor progress of task batches. The count is approximate due to relaxed atomic ordering. Not for precise synchronization.

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.