blocking_pool 0.2.0

A thread pool for running synchronous I/O in asynchronous applications
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 std::thread;
use std::time::Duration;

use criterion::Criterion;

use blocking_pool::ThreadPool;

fn main() {
    let mut c = Criterion::default().configure_from_args();

    let pool = ThreadPool::new();

    // Make sure a thread exists on the thread pool to begin with, to give more consistent results.
    pool.spawn_boxed(Box::new(|| {}));

    c.bench_function("noop", |b| {
        b.iter(|| {
            pool.spawn_boxed(Box::new(|| {}));
            pool.wait_all_complete();
        });
    });

    let sleep = || thread::sleep(Duration::from_micros(1));
    c.bench_function("sleeping task", |b| {
        b.iter(|| {
            pool.spawn_boxed(Box::new(sleep));
            pool.wait_all_complete();
        });
    });
}