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

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

use parallel_worker::{State, Worker};

fn main() {
    let worker = Worker::new(worker_function);

    worker.add_task(1);
    worker.add_task(2);
    worker.add_task(3);

    let results = worker.get_vec_blocking();
    println!("Results: {:?}", results);
}

fn worker_function(task: u64, state: &State) -> Option<u64> {
    sleep(Duration::from_secs(task));

    println!("Task completed after {} seconds", task);

    Some(task)
}