taskvisor 0.7.0

In-process Tokio task supervisor with retries, reliable outcomes, and per-key queue/replace/reject admission
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

//! # Basic: run one task
//!
//! This example shows the smallest static setup: create a task, run it once, and wait for the supervisor to finish.
//!
//! It uses:
//! - `TaskFn::arc` to turn an async closure into a `TaskRef`;
//! - `TaskSpec::once` to disable restarts;
//! - `Supervisor::run` to start the task and wait for completion.
//!
//! The task finishes at once. It does not use its `TaskContext`.
//! A long-running task should observe cancellation; see `worker.rs`.
//!
//! Run with `cargo run --example basic`.

use taskvisor::prelude::*;

#[tokio::main(flavor = "current_thread")]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let task: TaskRef = TaskFn::arc("hello", |_ctx| async move {
        println!("Hello from taskvisor!");
        Ok(())
    });

    let supervisor = Supervisor::new(SupervisorConfig::default(), vec![]);
    supervisor.run(vec![TaskSpec::once(task)]).await?;

    Ok(())
}