messaging_thread_pool 5.0.3

A library for aiding the creation of typed thread pool of objects that is communicated with via channels
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

use criterion::{Criterion, criterion_group, criterion_main};
use messaging_thread_pool::{ThreadPool, samples::*};

pub fn criterion_benchmark(c: &mut Criterion) {
    let thread_pool = ThreadPool::<Randoms>::new(10);

    // create 100 randoms
    thread_pool
        .send_and_receive((0..100).map(RandomsAddRequest))
        .expect("thread pool to exist")
        .for_each(|_| {});

    c.bench_function("sum 100 randoms", |b| {
        b.iter(|| {
            // send sum requests to all 100 randoms
            thread_pool
                .send_and_receive((0..100).map(SumRequest))
                .expect("thread pool to exist")
                .for_each(|_| {});
        })
    });
}

criterion_group!(benches, criterion_benchmark);
criterion_main!(benches);