CoachMan

coachman is a rust asynchronous task manager built on top of tokio framework.

Features

• Task count control: coachman allows you to control task count preventing your application from uncontrolled task count explosion.
• Task cancellation: The main feature of coachman is task cancellation. It provides a simple api for making your task cancelable.

Basic example

The main feature of coachman is making asynchronous tasks cancelable.

Look at the following example:

``` rust use coachman as cm; use coachman::{try_await, Canceled, Completed, TaskError};

async fn innerfunc(i: usize, duration: u64) { match tryawait!(tokio::time::sleep(std::time::Duration::fromsecs(duration))) { Canceled => println!("task#{} inner canceled", i), Completed() => println!("task#{} inner completed", i), } }

async fn outerfunc(i: usize, duration: u64) { match tryawait!(innerfunc(i, duration)) { Canceled => println!("task#{} outer canceled", i), Completed() => println!("task#{} outer completed", i), } }

[tokio::main(flavor = "current_thread")]

async fn main() { let mut taskhandles = Vec::new(); for i in 0..5 { let duration = i as u64; taskhandles.push(cm::spawn(outer_func(i, duration))); }

let deadline = tokio::time::Instant::now() + std::time::Duration::fromsecs(2); for (i, mut handle) in taskhandles.intoiter().enumerate() { if tokio::time::timeoutat(deadline, &mut handle).await.isok() { println!("task-{} completed", i); } else { handle.cancel(); match handle.await { Result::Err(TaskError::Canceled) => println!("task-{} canceled", i), Result::Err(TaskError::Aborted) => println!("task-{} aborted", i), Result::Err(TaskError::Panicked()) => println!("task-{} panicked", i), Result::Ok(_) => unreachable!(), } } } } ```