beekeeper 0.3.0

A full-featured worker pool library for parallelizing tasks
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

use beekeeper::bee::stock::EchoWorker;
use beekeeper::hive::{Builder, ChannelBuilder, TaskQueuesBuilder, outcome_channel};
use divan::{AllocProfiler, Bencher, bench, black_box_drop};
use itertools::iproduct;

#[global_allocator]
static ALLOC: AllocProfiler = AllocProfiler::system();

const THREADS: &[usize] = &[1, 4, 8, 16];
const TASKS: &[usize] = &[1, 100, 10_000, 1_000_000];

#[bench(args = iproduct!(THREADS, TASKS))]
fn bench_apply_short_task(bencher: Bencher, (num_threads, num_tasks): (&usize, &usize)) {
    let hive = ChannelBuilder::empty()
        .num_threads(*num_threads)
        .with_worker_default::<EchoWorker<usize>>()
        .build();
    bencher.bench_local(|| {
        let (tx, rx) = outcome_channel();
        for i in 0..*num_tasks {
            hive.apply_send(i, &tx);
        }
        hive.join();
        rx.into_iter().take(*num_tasks).for_each(black_box_drop);
    })
}

fn main() {
    divan::main();
}