#iterator #chunk #parallel-iterator

arbitrary-chunks

An iterator that allows specifying an input array of arbitrary chunk-sizes with which to split a vector or array

4 releases (2 breaking)

0.4.1 Feb 22, 2023
0.4.0 Nov 24, 2021
0.3.0 Nov 17, 2021
0.2.1 Jul 27, 2021

#1053 in Data structures

Download history 123/week @ 2024-07-21 159/week @ 2024-07-28 123/week @ 2024-08-04 122/week @ 2024-08-11 125/week @ 2024-08-18 135/week @ 2024-08-25 191/week @ 2024-09-01 139/week @ 2024-09-08 206/week @ 2024-09-15 211/week @ 2024-09-22 338/week @ 2024-09-29 214/week @ 2024-10-06 177/week @ 2024-10-13 219/week @ 2024-10-20 262/week @ 2024-10-27 380/week @ 2024-11-03

1,047 downloads per month
Used in 10 crates (via rdst)

Apache-2.0 OR MIT

24KB
332 lines

arbitrary-chunks

Crates.io Crates.io

An iterator that allows specifying an input array of arbitrary chunk-sizes with which to split a vector or array. As with the standard .chunks(), this iterator also includes _mut(), _exact() and _exact_mut() variants.

Usage

By default, this iterator is implemented for [T], meaning it works for both arrays and Vec of any type.

If there is not enough data to satisfy the provided chunk length, you will get all the remaining data for that chunk, so it will be shorter than expected. To instead stop early if there is not enough data, see the .arbitrary_chunks_exact() variant.

use arbitrary_chunks::ArbitraryChunks;

let chunks: Vec<usize> = vec![1, 3, 1];
let data: Vec<i32> = vec![0, 1, 2, 3, 4];

let chunked_data: Vec<Vec<i32>> = data
    .arbitrary_chunks(&chunks)
    .map(|chunk| chunk.to_vec())
    .collect();

assert_eq!(vec![0], chunked_data[0]);
assert_eq!(vec![1, 2, 3], chunked_data[1]);
assert_eq!(vec![4], chunked_data[2]);

Exact Variant

Unlike the regular variant, the exact variant's iterator will end early if there is not enough data to satisfy the chunk. Instead, you will be able to access the remainder of the data with .remainder().

use arbitrary_chunks::ArbitraryChunks;

let chunks: Vec<usize> = vec![1, 3];
let data: Vec<i32> = vec![0, 1, 2];
let mut iter = data.arbitrary_chunks_exact(&chunks);

assert_eq!(vec![0], iter.next().unwrap());
assert_eq!(None, iter.next());
assert_eq!(vec![1, 2], iter.remainder());

Mutable Variants

Each of the regular and exact variants also have their own mutable variants. These allow you to mutably modify slices and vectors in arbitrarily-sized chunks.

use arbitrary_chunks::ArbitraryChunks;

let chunks: Vec<usize> = vec![1, 3, 1];
let data: Vec<i32> = vec![0, 1, 2, 3, 4];

let iter_1 = data.arbitrary_chunks_mut(&chunks);
let iter_2 = data.arbitrary_chunks_exact_mut(&chunks);

Parallel Iterator

This can be used in parallel with rayon using .par_bridge(), for example:

use arbitrary_chunks::ArbitraryChunks;
use rayon::prelude::*;

let chunks: Vec<usize> = vec![1, 3, 1];
let data: Vec<i32> = vec![0, 1, 2, 3, 4];

data
    .arbitrary_chunks(&chunks)
    .par_bridge()
    .for_each(|chunk| {
        assert!(chunk.len() >= 1 && chunk.len() <= 3);
        println!("{:?}", chunk);
    });

// Prints (in pseudo-random order):
// [1, 2, 3]
// [0]
// [4]

Motivation

This library was inspired by the need to mutably modify many sections of the same slice concurrently. With this library plus Rayon, you are able to mutably borrow and modify slices safely from many threads at the same time, without upsetting the borrow checker.

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.

No runtime deps