orx-concurrent-iter 4.1.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
30
31
32
33
34

use super::con_iter::ConIterRange;
use crate::{
    concurrent_iterable::ConcurrentIterable,
    implementations::range::into_con_iter::range_inclusive_to_range,
};
use core::ops::{Range, RangeInclusive};

impl<T> ConcurrentIterable for Range<T>
where
    T: Send + From<usize> + Into<usize>,
    Range<T>: Default + Clone + ExactSizeIterator<Item = T>,
{
    type Item = T;

    type Iter = ConIterRange<T>;

    fn con_iter(&self) -> Self::Iter {
        Self::Iter::new(self.clone())
    }
}

impl<T> ConcurrentIterable for RangeInclusive<T>
where
    T: Send + From<usize> + Into<usize> + Clone,
    Range<T>: Default + Clone + ExactSizeIterator<Item = T>,
{
    type Item = T;

    type Iter = ConIterRange<T>;

    fn con_iter(&self) -> Self::Iter {
        range_inclusive_to_range(self.clone()).con_iter()
    }
}