lol-core 0.9.5

A Raft implementation in Rust language.
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
33
34
35
36
37
38
39
40
41
42
43
44

use tokio::task::JoinHandle;

/// Mechanism to drop spawned threads when the owner drops.
#[derive(Debug)]
pub struct ThreadDrop {
    handles: Vec<JoinHandle<()>>,
}
impl ThreadDrop {
    pub fn new() -> Self {
        Self { handles: vec![] }
    }
    pub fn register_abort_on_drop(&mut self, hdl: JoinHandle<()>) {
        self.handles.push(hdl);
    }
}
impl Drop for ThreadDrop {
    fn drop(&mut self) {
        for hdl in &mut self.handles {
            hdl.abort();
        }
    }
}

#[cfg(test)]
mod tests {
    use super::*;

    #[tokio::test]
    async fn test_thread_drop() {
        use std::time::Duration;
        let hdl = tokio::spawn(async {
            loop {
                println!("I am alive!!!");
                tokio::time::sleep(Duration::from_millis(1)).await;
            }
        });
        tokio::time::sleep(Duration::from_secs(1)).await;
        let mut td = ThreadDrop::new();
        td.register_abort_on_drop(hdl);
        drop(td);
        println!("Dropped. It should be silent now.");
        tokio::time::sleep(Duration::from_secs(1)).await;
    }
}