swansong 0.3.4

Graceful Shutdown
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

fn main() {
    use std::{thread, time::Duration};
    use swansong::Swansong;
    let swansong = Swansong::new();

    thread::spawn({
        let guard = swansong.guard();
        move || {
            let _guard = guard;
            thread::sleep(Duration::from_secs(1));
        }
    });

    thread::spawn({
        let swansong = swansong.clone();
        move || {
            for n in swansong
                .interrupt(std::iter::repeat_with(|| fastrand::u8(..)))
                .guarded()
            {
                thread::sleep(Duration::from_millis(100));
                println!("{n}");
            }
        }
    });

    thread::sleep(Duration::from_millis(500));

    swansong.shut_down().block();
}