Struct TrackedTaskGroup 

pub struct TrackedTaskGroup { /* private fields */ }

A group of spawned tasks whose lifecycle is tracked.

When finalize is called, the group joins each handle with the configured grace period and reports any tasks still running as leaks.

Example

use dev_async::tasks::TrackedTaskGroup;
use std::time::Duration;

let mut group = TrackedTaskGroup::new("workers");
group.spawn(async { tokio::time::sleep(Duration::from_millis(5)).await; });
group.spawn(async { tokio::time::sleep(Duration::from_millis(5)).await; });

let check = group.finalize(Duration::from_millis(50)).await;
assert!(check.has_tag("async"));

Implementations

impl TrackedTaskGroup

pub fn new(name: impl Into<String>) -> Self

Create a new group with a stable name.

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

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

Spawn a future and track its handle.

The future MUST resolve to (). If you need a result, capture it via shared state (e.g. tokio::sync::oneshot::Sender).

pub fn spawned_count(&self) -> usize

How many tasks have been spawned through this group so far.

pub async fn finalize(self, grace: Duration) -> CheckResult

Join all tracked tasks with a per-task grace period and emit a CheckResult.

Verdicts:

• All tasks completed cleanly -> Pass.
• One or more tasks panicked -> Fail (Critical) with task_panicked tag.
• One or more tasks did not finish in time (leak suspected) -> Fail (Error) with task_leak tag.