orx-parallel 4.0.0

Performant parallel computations with an expressive iterator API.
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::infallible::{ParIter, xap_variants::Id};
use crate::runner::default_runner;
use orx_concurrent_iter::ConcurrentIterable;

/// Adds `.par()` to concurrent iterables.
///
/// Sequential counterpart: creating and using a regular iterator via `iter()` or `into_iter()`.
pub trait Parallelizable: ConcurrentIterable {
    /// Returns a parallel iterator over items of this iterable.
    ///
    /// # Example
    ///
    /// ```
    /// use orx_parallel::*;
    ///
    /// let sum: usize = (0..10).par().sum();
    /// assert_eq!(sum, 45);
    /// ```
    fn par(&self) -> ParIter<Self::Iter, Id<Self::Item>> {
        ParIter::new(
            self.con_iter(),
            Id::new(),
            default_runner(),
            Default::default(),
        )
    }
}

impl<I> Parallelizable for I where I: ConcurrentIterable {}