scoped-threadpool-std 0.1.1

A simple scoped threadpool implementation and related tests including a password hasher
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

#![feature(scoped_threads)]
mod common;

use scoped_threadpool_std::thread_pool::ThreadPool;

const MAX_CANDIDATE: u64 = 100000;
const NUM_THREADS_PER_POOL: usize = 8;
const NUM_THREADPOOLS: usize = 10;

#[test]
pub fn primes_multiple_pools() {
    std::thread::scope(|scope| {
        let mut pools: Vec<ThreadPool> = Vec::with_capacity(NUM_THREADPOOLS);
        for _ in 0..NUM_THREADPOOLS {
            pools.push(ThreadPool::new(NUM_THREADS_PER_POOL, scope))
        }
        for i in 2..MAX_CANDIDATE {
            pools[i as usize % NUM_THREADPOOLS].execute(move || {
                common::check_prime(i);
            });
        }
    });
}