Struct tokio_task_tracker::TaskWaiter

pub struct TaskWaiter { /* private fields */ }

TaskWaiter is used to wait until all task trackers have been dropped.

Implementations

impl TaskWaiter

pub fn cancel(&self)

Notify all tasks this TaskWaiter is waiting on that they should abort.

pub async fn wait_for_shutdown(self, timeout: Duration) -> Result<(), Error>

Wait for the application to be interrupted, and then gracefully shutdown allowing a timeout for all tasks to quit. A second interrupt will cause an immediate shutdown.

On Unix systems, “interrupt” means a SIGINT or SIGTERM. On all other platforms the current implementation uses tokio::signal::ctrl_c() to wait for an interrupt.

pub async fn wait_with_timeout(self, timeout: Duration) -> Result<(), Error>

Wait for all tasks to finish. If tasks do not finish before the timeout, Error::Timeout will be returned.

pub async fn wait(self)

Wait for all tasks to finish.