🤖 task-supervisor

task-supervisor helps you keep Tokio tasks alive. It watches each task, restarts it if it crashes or stops responding, and lets you add, restart, or kill tasks at runtime.

Install

cargo add task-supervisor

Quick example

use async_trait::async_trait;
use task_supervisor::{SupervisorBuilder, SupervisedTask, TaskResult};

#[derive(Clone)]
struct Printer;

#[async_trait]
impl SupervisedTask for Printer {
    async fn run(&mut self) -> TaskResult {
        println!("hello");
        Ok(())
    }
}

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let supervisor = SupervisorBuilder::default()
        .with_task("printer", Printer)
        .build()
        .run();

    supervisor.wait().await?;   // wait until every task finishes or is killed
    Ok(())
}

What you get

• Automatic restarts – tasks are relaunched after a crash or hang (exponential back-off).
• Dynamic control – add, restart, kill, or query tasks through a SupervisorHandle.
• Configurable – tune health-check interval, restart limits, back-off delay, and shutdown policy.

API overview

Full documentation lives on docs.rs.

License

MIT