#shutdown #async

killswitch

Killswitch used to broadcast a shutdown request

3 releases (breaking)

0.4.0 Sep 8, 2022
0.3.0 Aug 10, 2021
0.2.1 Mar 3, 2021
0.2.0 Mar 2, 2021
0.1.1 Mar 2, 2021

#344 in Asynchronous

25 downloads per month
Used in ddmw-client

0BSD license

16KB
298 lines

killswitch

A killswitch is a special-purpose channel-like object used to signal to tasks that they should terminate.


lib.rs:

Signal a request for (multiple) async tasks to self-terminate.

use std::error::Error;
use tokio::time::{sleep, Duration};
use killswitch::KillSwitch;

#[tokio::main]
async fn main() -> Result<(), Box<dyn Error>> {
  let ks = KillSwitch::new();

  tokio::spawn(killable(String::from("test1"), ks.clone()));
  tokio::spawn(killable(String::from("test2"), ks.clone()));

  sleep(Duration::from_secs(1)).await;

  println!("Triggering kill switch");
  ks.trigger();

  tokio::spawn(killable(String::from("test3"), ks.clone()));
  tokio::spawn(killable(String::from("test4"), ks.clone()));

  // Wait for all waiters to drop
  ks.finalize().await;

  Ok(())
}

async fn killable(s: String, ks: KillSwitch) {
  println!("killable({}) entered", s);
  ks.wait().await;
  println!("killable({}) leaving", s);
}

killswitch was developed to help create abortable async tasks in conjuction with multiple-wait features such as the tokio::select! macro.

Dependencies

~0.4–5MB
~79K SLoC