ice-threads 0.1.0

Lightweight Thread pool implementation.
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

use crate::IceBox;

use std::{
    thread,
    thread::JoinHandle
};
use std::sync::{
    Arc, Mutex,
    mpsc::Receiver
};


// Heater, used to melt Ice
pub(crate) struct Heater {
    core: Option<JoinHandle<()>>
}

impl Heater {
    // Creates a new Heater that waits for Ice to be sent
    pub fn new(ice_boxes: Arc<Mutex<Receiver<IceBox>>>) -> Heater {
        let core = thread::Builder::new().name("Heater".to_string()).spawn(move || {
            loop {
                let icebox = ice_boxes.lock().unwrap()
                                      .recv().unwrap();

                match icebox {
                    IceBox::Some(ice) => ice.melt(),
                    IceBox::None      => break
                }
            }
        }).expect("ice_threads::Heater::new -> Could not create a new instance");

        Heater {
            core: Some(core)
        }
    }

    // Heater allows it's core to be taken out
    // Used by Melter when shutting down
    pub fn take_core(&mut self) -> Option<JoinHandle<()>> {
        self.core.take()
    }
}