#ring-buffer #spsc #indexed #multiple #readable #index #absolute

indexed-ring-buffer

An indexed multiple readable spsc ring buffer

4 releases

0.1.3 Feb 13, 2020
0.1.2 Feb 4, 2020
0.1.1 Jan 31, 2020
0.1.0 Jan 31, 2020

#1078 in Concurrency

Download history 33/week @ 2024-02-18 10/week @ 2024-02-25 5/week @ 2024-03-03 43/week @ 2024-03-10

91 downloads per month

MIT/Apache

15KB
288 lines

Indexed Ring Buffer

An indexed multiple readable spsc ring buffer.

Overview

  • access by an absolute index.
  • a single-producer single-consumer with multi-reader.
  • using RwLock of parking_lot.

Examples

extern crate indexed_ring_buffer;
use indexed_ring_buffer::*;

let (mut p, mut c, r) = indexed_ring_buffer::<usize>(0, 5);

for i in 0..101 {
    p.push(i);
    c.shift();
}

for i in 101..106 {
    p.push(i);
}

let (start, end, data) = r.get_from(101,5).unwrap();
assert_eq!(data,vec![101,102,103,104,105]);
assert_eq!(start,101);
assert_eq!(end,105);

c.shift_to(105);
let rslt = r.get_all();
assert_eq!(rslt,None);

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.5–0.8MB
~13K SLoC