parallel_worker 0.1.0

A parallel worker implementation in Rust. Allows to start tasks in parallel and receive the results blocking or non-blocking.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use std::{thread::sleep, time::Duration};

use parallel_worker::{State, Worker};

fn main() {
    let worker = Worker::new(|n: u64, _s: &State| {
        sleep(Duration::from_secs(n));
        Some(n)
    });

    worker.add_task(7);
    worker.add_task(1);
    worker.add_task(5);
    worker.add_task(2);
    worker.add_task(6);
    worker.add_task(3);
    worker.add_task(4);
    worker.add_task(8);

    for result in worker.get_iter_blocking() {
        println!("Result: {:?}", result);
    }
}