lib-wc 0.2.0

Will's Programming Toolbox
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

use std::sync::atomic::AtomicUsize;

use lib_wc::executors::{RayonThreadPool, ThreadPool, ThreadPoolError};
use std::sync::atomic::Ordering::Acquire;

fn main() -> Result<(), ThreadPoolError> {
    static COUNT: AtomicUsize = AtomicUsize::new(0);

    let pool = RayonThreadPool::new(2)?;

    pool.spawn(|| println!("All jobs should run before the program exits!"));

    for _ in 0..100 {
        pool.spawn(move || {
            COUNT.fetch_add(1, Acquire);
        });
    }

    pool.shutdown();

    assert_eq!(COUNT.load(Acquire), 100);

    Ok(())
}