Struct ringbuffer_spsc::RingBufferWriter
source · pub struct RingBufferWriter<T, const N: usize> { /* private fields */ }
Implementations§
source§impl<T, const N: usize> RingBufferWriter<T, N>
impl<T, const N: usize> RingBufferWriter<T, N>
sourcepub fn push(&mut self, t: T) -> Option<T>
pub fn push(&mut self, t: T) -> Option<T>
Examples found in repository?
examples/throughput.rs (line 13)
6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39
fn main() {
let (mut tx, mut rx) = RingBuffer::<usize, 16>::init();
let counter = Arc::new(AtomicUsize::new(0));
std::thread::spawn(move || {
let mut current: usize = 0;
loop {
if tx.push(current).is_none() {
current = current.wrapping_add(1);
} else {
std::thread::yield_now();
}
}
});
let c_counter = counter.clone();
std::thread::spawn(move || {
let mut current: usize = 0;
loop {
if let Some(c) = rx.pull() {
assert_eq!(c, current);
current = current.wrapping_add(1);
c_counter.fetch_add(1, Ordering::Relaxed);
} else {
std::thread::yield_now();
}
}
});
loop {
std::thread::sleep(Duration::from_secs(1));
println!("{} elem/s", counter.swap(0, Ordering::Relaxed));
}
}