workpool 0.1.1

Distribute work to a set of threads and wait for completion
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

use std::thread::{self, JoinHandle};

/// JoinOnDrop wraps a thread::JoinHandle and ensures that the thread is joined
/// on drop.
#[derive(Debug)]
pub struct JoinOnDrop<T>(Option<JoinHandle<T>>);

impl<T> JoinOnDrop<T> {
    /// wrap a thread::JoinHandle returning a JoinOnDrop.
    pub fn wrap(handle: JoinHandle<T>) -> JoinOnDrop<T> {
        JoinOnDrop(Some(handle))
    }

    // Join the thread.
    pub fn join(mut self) -> thread::Result<T> {
        self.0.take().unwrap().join()
    }

    // Access the underlying thread.
    pub fn thread(&self) -> &thread::Thread {
        self.0.as_ref().unwrap().thread()
    }
}

impl<T> Drop for JoinOnDrop<T> {
    fn drop(&mut self) {
        if let Some(join_handle) = self.0.take() {
            let _ = join_handle.join();
        }
    }
}