Function wscale_threads

tests/cpp/wscale.rs:47–70

(num_threads: usize)

}

fn wscale_threads(num_threads: usize) {
    let tree = Arc::new(MassTree15Inline::<u64>::new());
    let per_thread = N / num_threads;

    let handles: Vec<_> = (0..num_threads)
        .map(|tid| {
            let tree = Arc::clone(&tree);
            thread::spawn(move || {
                let guard = tree.guard();
                let mut rng = StdRng::seed_from_u64(SEED + tid as u64);

                for _ in 0..per_thread {
                    let x: u64 = rng.random();
                    let key = x.to_be_bytes();
                    let _ = tree.insert_with_guard(&key, x + 1, &guard);
                }
            })
        })
        .collect();

    for h in handles {
        h.join().unwrap();
    }
}