5 releases
Uses new Rust 2024
new 0.1.4 | Mar 24, 2025 |
---|---|
0.1.3 | Mar 24, 2025 |
0.1.2 | Mar 24, 2025 |
0.1.1 | Mar 20, 2025 |
0.1.0 | Mar 20, 2025 |
#275 in Concurrency
468 downloads per month
25KB
490 lines
Parallel Worker
This crate provides a simple interface for running tasks in parallel.
The Worker
or BasicWorker
struct are used to dispatch tasks to worker threads and collect the results.
You can wait for results or recieve currently available results.
Workers
There are two types of workers:
BasicWorker
is a simple worker that processes tasks in parallel using multiple worker threads.Worker
has additional functionality for optional results and task cancelation during execution.
Example
use parallel_worker::prelude::*;
fn main() {
let worker = BasicWorker::new(|n: u64| 42);
worker.add_task(1);
worker.add_task(2);
assert_eq!(worker.get_blocking(), Some(42));
worker.add_tasks(0..10);
assert_eq!(worker.get_iter_blocking().count(), 11);
}
Tasks can be canceled
Canceled tasks will stop executing as soon as they reach a check_if_cancelled!
.
Results of canceled tasks will be discarded even if they have already been computed.
use parallel_worker::prelude::*;
fn main() {
let worker = Worker::new(worker_function);
worker.add_task(1);
worker.cancel_tasks();
assert!(worker.get_blocking().is_none());
}
fn worker_function(task: u64, state: &State) -> Option<u64> {
for i in 0.. {
sleep(Duration::from_millis(50)); // Do some work
check_if_cancelled!(state); // Check if the task has been canceled
}
Some(42)
}
Results can be optional
If a worker returns None
the result will be discarded.
use parallel_worker::prelude::*;
fn main() {
let worker = Worker::new(|n: u64, _s: &State| {
if n % 2 == 0 {
Some(n)
} else {
None
}
});
worker.add_tasks(1..=10);
assert_eq!(worker.get_iter_blocking().count(), 5);
}