orx-concurrent-iter 3.3.0

A thread-safe and ergonomic concurrent iterator trait and efficient lock-free implementations.
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
26
27
28
29

use crate::{IntoConcurrentIter, concurrent_iter::ConcurrentIter};
use alloc::vec::Vec;
use orx_concurrent_bag::ConcurrentBag;

#[test]
fn slice_as_into_concurrent_iter() {
    let (nt, n) = (2, 177);
    let mut vec: Vec<_> = (0..n).collect();
    let slice = vec.as_mut_slice();

    let iter = slice.into_con_iter();

    let num_spawned = ConcurrentBag::new();
    std::thread::scope(|s| {
        for _ in 0..nt {
            s.spawn(|| {
                num_spawned.push(true);
                while num_spawned.len() < nt {} // allow all threads to be spawned

                while let Some(x) = iter.next() {
                    *x += 1;
                }
            });
        }
    });

    let expected: Vec<_> = (1..(n + 1)).collect();
    assert_eq!(expected, vec);
}