thread_binder 0.1.0

Bind rayon pools to limit numa effects
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 rayon::prelude::*;
use thread_binder::ThreadPoolBuilder;

// let's have a slow computation so you can take time checking
// the binding with htop
pub fn fibonacci_recursive(n: u64) -> u64 {
    match n {
        0 | 1 => n,
        _ => fibonacci_recursive(n - 1) + fibonacci_recursive(n - 2),
    }
}

fn main() {
    ThreadPoolBuilder::new()
        .num_threads(4)
        .build_global()
        .expect("Thread pool build failed");

    let fibo: Vec<_> = (0..46u64)
        .into_par_iter()
        .map(|i| fibonacci_recursive(i))
        .collect();
    assert_eq!(fibo[0], 0);
    println!("{:?}", fibo);
}