threads_pool 0.2.6

This package provides an easy way to create and manage thread pools, so you don't have to.
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
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53

#[macro_use]
extern crate criterion;
extern crate threads_pool;

use criterion::{black_box, Criterion};
use std::sync::atomic;
use threads_pool::prelude::*;

fn pool_base(size: usize, bound: usize) {
    let mut pool = ThreadPool::new(size);

    for num in 1..bound {
        pool.exec(
            move || {
                for _ in 1..num % 4 {
                    atomic::spin_loop_hint();
                }
            },
            false,
        )
        .unwrap_or_default();
    }

    pool.close();
}

fn pool_bench(c: &mut Criterion) {
    c.bench_function("base pool measurement", |b| {
        b.iter(|| pool_base(black_box(16), black_box(400)))
    });
}

fn single_bench(c: &mut Criterion) {
    shared_mode::initialize(black_box(16));
    let bound = black_box(400);

    c.bench_function("base single mode measurement", move |b| {
        b.iter(|| {
            for num in 1..bound {
                shared_mode::run(move || {
                    for _ in 1..num % 16 {
                        atomic::spin_loop_hint();
                    }
                });
            }
        })
    });

    shared_mode::close();
}

criterion_group!(benches, pool_bench, single_bench);
criterion_main!(benches);