7 releases

Uses new Rust 2021

new 0.0.7 May 11, 2022
0.0.6 May 11, 2022
0.0.5 Sep 24, 2021

#174 in Asynchronous

Download history 2/week @ 2022-02-06 5/week @ 2022-02-20 5/week @ 2022-02-27 3/week @ 2022-03-06 20/week @ 2022-03-13 19/week @ 2022-03-20 6/week @ 2022-04-03 1/week @ 2022-04-17 20/week @ 2022-04-24 56/week @ 2022-05-01 120/week @ 2022-05-08

197 downloads per month

Apache-2.0

47KB
942 lines

Double Mapped Circular Buffer

  • Thread-safe.
  • Supports multiple readers.
  • Generic over the item type.
  • Provides access to all items (not n-1).
  • Supports Linux, macOS, Windows, and Android.
  • Sync, async, and non-blocking implementations.
  • Generic variant that allows specifying custom Notifiers to ease integration.
  • Underlying data structure (i.e., DoubleMappedBuffer) is exported to allow custom implementations.

Crates.io Apache 2.0 licensed Build Status

Overview

This circular buffer implementation maps the underlying buffer twice, back-to-back into the virtual address space of the process. This arrangement allows the circular buffer to present the available data sequentially, (i.e., as a slice) without having to worry about wrapping.

Example

use vmcircbuffer::sync;

let mut w = sync::Circular::new::<u32>()?;
let mut r = w.add_reader();

// delay producing by 1 sec
let now = std::time::Instant::now();
let delay = std::time::Duration::from_millis(1000);

// producer thread
std::thread::spawn(move || {
    std::thread::sleep(delay);
    let w_buff = w.slice();
    for v in w_buff.iter_mut() {
        *v = 23;
    }
    let l = w_buff.len();
    w.produce(l);
});

// blocks until data becomes available
let r_buff = r.slice().unwrap();
assert!(now.elapsed() > delay);
for v in r_buff {
    assert_eq!(*v, 23);
}
let l = r_buff.len();
r.consume(l);

Contributions

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the project, shall be licensed as Apache 2.0, without any additional terms or conditions.

Dependencies

~0.3–1MB
~21K SLoC