tokio-task-supervisor 0.1.1

Tokio TaskTracker with built-in cancellation token management and coordinated shutdown.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20

use std::time::Duration;

use tokio_task_supervisor::TaskSupervisor;

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let supervisor = TaskSupervisor::new();

    for id in 0..3 {
        let _ = supervisor.spawn_with_token(move |_token| async move {
            println!("task {id}: started");
            tokio::time::sleep(Duration::from_secs((id + 1) as u64)).await;
            println!("task {id}: finished after waiting");
        });
    }

    println!("main: calling shutdown so all tasks complete");
    supervisor.shutdown().await;
    println!("main: all background tasks done");
}