10 breaking releases

0.12.0 Jun 27, 2022
0.10.0 May 27, 2022

#693 in Concurrency

Download history 976/week @ 2024-03-13 489/week @ 2024-03-20 771/week @ 2024-03-27 568/week @ 2024-04-03 1177/week @ 2024-04-10 784/week @ 2024-04-17 717/week @ 2024-04-24 1144/week @ 2024-05-01 471/week @ 2024-05-08 234/week @ 2024-05-15 534/week @ 2024-05-22 434/week @ 2024-05-29 336/week @ 2024-06-05 518/week @ 2024-06-12 429/week @ 2024-06-19 337/week @ 2024-06-26

1,647 downloads per month
Used in 4 crates (via voronator)

MIT/Apache

17KB
363 lines

maybe_parallel_iterator

Write your code once. Then toggle between sequential and parallel iterators with a feature flag!

let a: Vec<i32> = (0..100).collect();
a.into_maybe_parallel_iterator()
    .with_min_sequential(2)
    .map(|n| -n)
    .enumerate()
    .flat_map(|(e, n)| vec![e as i32, n, n + 1000].into_maybe_parallel_iterator())
    .for_each(|item| {
        println!("par: {:?}", item);
    })

Features

  • Iterators
    • into_maybe_par_iter
    • maybe_par_iter
    • maybe_par_iter_mut
  • Sorts
    • maybe_par_sort
    • maybe_par_sort_unstable
    • maybe_par_sort_by
    • maybe_par_sort_unstable_by
    • maybe_par_sort_by_key
    • maybe_par_sort_unstable_by_key

Use the rayon feature flag to enable rayon parallelism.

The default is sequential ("rayoff" mode).

Limitations

For now, only supports these iterator adapters:

  • collect
  • *enumerate
  • filter_map
  • find_any
  • flat_map
  • for_each
  • map
  • *with_min_sequential (no-op unless rayon feature enabled)

*Only available for IndexedParallelIterator's if rayon feature enabled.

License

Licensed under either of

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

Dependencies

~0–265KB