status_executor 0.1.0

Run your work on some context (thread) and get status info back
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

use rayon::ThreadPoolBuilder;
use status_executor::{RayonContext, StatusExecutor, StatusSender};

fn takes_a_while(s: StatusSender<String>) -> i32 {
    for i in 0..100 {
        s.send(format!("Currently at {}", i).to_string());
        std::thread::sleep(std::time::Duration::from_millis(13));
        rayon::yield_now();
    }
    s.send("Done!".to_string());
    100
}

fn main() {
    let pool = ThreadPoolBuilder::new().num_threads(2).build().unwrap();
    let e1 = StatusExecutor::new(RayonContext::new(&pool), takes_a_while);
    std::thread::sleep(std::time::Duration::from_millis(100));
    let e2 = StatusExecutor::new(RayonContext::new(&pool), takes_a_while);

    while !e1.is_done() || !e2.is_done() {
        if let Some(s) = e1.status() {
            println!("E1: {}", s);
        }
        if let Some(s) = e2.status() {
            println!("E2: {}", s);
        }
    }

    println!(
        "E1: {} - {}",
        e1.latest_status().unwrap(),
        e1.take_result().unwrap()
    );
    println!(
        "E2: {} - {}",
        e2.latest_status().unwrap(),
        e2.take_result().unwrap()
    );
}