sigterm 0.3.10

Signal-aware async control and cancellation primitives for Tokio.
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
29
30
31
32

/* examples/broadcast.rs */

//! Example of using `Broadcast` for multiple tasks.

use sigterm::Broadcast;
use std::time::Duration;
use tokio::time::sleep;

#[tokio::main]
async fn main() {
	let broadcast = Broadcast::new();

	// Spawn multiple worker tasks
	for i in 1..=3 {
		let sub = broadcast.subscribe();
		tokio::spawn(async move {
			println!("Worker {} started...", i);
			sub.recv().await;
			println!("Worker {} shutting down!", i);
		});
	}

	// Simulate work
	sleep(Duration::from_secs(2)).await;

	println!("Triggering global shutdown...");
	broadcast.shutdown();

	// Give tasks time to print their shutdown message
	sleep(Duration::from_millis(100)).await;
	println!("Main exited.");
}