parallel_worker 1.0.2

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

use std::thread::available_parallelism;

/// Methods for creating a worker.
pub trait WorkerInit<T, R, F>
where
    Self: Sized,
{
    /// Create a new worker with a given number of worker threads and a worker function.
    /// Spawns worker threads that will process tasks from the queue using the worker function.
    fn with_num_threads(num_worker_threads: usize, worker_function: F) -> Self;

    /// Create a new worker with a given worker function.
    /// The number of worker threads will be set to the number of available logical cores minus one.
    /// Spawns worker threads that will process tasks from the queue using the worker function.
    fn new(worker_function: F) -> Self {
        let num_worker_threads = available_parallelism()
            .map(|n| n.get().saturating_sub(1))
            .unwrap_or(1);
        Self::with_num_threads(num_worker_threads, worker_function)
    }
}