Struct TaskManager 

pub struct TaskManager { /* private fields */ }

Manages a collection of spawned tokio tasks.

This struct provides a centralized way to spawn, track, and manage the lifecycle of async tasks in the translator. It maintains a list of join handles that can be used to wait for all tasks to complete or abort them during shutdown.

Implementations

impl TaskManager

pub fn new() -> Self

Creates a new TaskManager instance.

Initializes an empty task manager ready to spawn and track tasks.

pub fn spawn<F>(&self, fut: F)

where F: Future<Output = ()> + Send + 'static,

Spawns a new async task and adds it to the managed collection.

The task will be tracked by this manager and can be waited for or aborted using the other methods.

Arguments

• fut - The future to spawn as a task

pub async fn join_all(&self)

Waits for all managed tasks to complete.

This method will block until all tasks that were spawned through this manager have finished executing. Tasks are joined in reverse order (most recently spawned first).

pub async fn abort_all(&self)

Aborts all managed tasks.

This method immediately cancels all tasks that were spawned through this manager. The tasks will be terminated without waiting for them to complete.

Trait Implementations

impl Default for TaskManager

fn default() -> Self

Returns the “default value” for a type.