multi_thread 0.1.0

Helps you run multiple threads which optionally share data.
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

use failure::Error;
use std::thread;
use std::thread::JoinHandle;

#[allow(dead_code)]
pub fn run_thread<F, T>(
    name: impl Into<String>,
    data: &T,
    entrypoint: F,
) -> Result<JoinHandle<()>, Error>
where
    F: Fn(T) -> Result<(), Error>,
    F: Send + Copy + 'static,
    T: Clone + Send + Sync + 'static,
{
    let data = data.clone();

    let builder = thread::Builder::new().name(name.into());

    let handle = builder.spawn(move || {
        if let Err(e) = entrypoint(data) {
            println!("{:?}", e);
            panic!("{:?}", e);
        }
    })?;

    Ok(handle)
}

pub fn join_threads<T>(handles: Vec<JoinHandle<T>>) {
    // TODO: propogate panics using thread-control
    // TODO: propogate errors using crossbeam channels
    // check this out for some more options: https://stackoverflow.com/questions/49846056/is-there-an-api-to-race-n-threads-or-n-closures-on-n-threads-to-completion?noredirect=1&lq=1
    for handle in handles {
        handle.join().expect("A child thread panicked.");
    }
}