magnetic 2.5.2

Low-latency lock-free queues
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24

use std::sync::atomic::AtomicUsize;

use super::buffer::Buffer;

// The caller guarantees that no references currently exist to the value at head
#[inline(always)]
pub unsafe fn buf_write<T, B: Buffer<T>>(buf: &B, head: usize, value: T) {
    let slot = unsafe { &mut *(*buf.at(head)).get() };
    slot.write(value);
}

// The caller guarantees that no references currently exist to the value at tail and the value is
// initialized.
#[inline(always)]
pub unsafe fn buf_read<T, B: Buffer<T>>(buf: &B, tail: usize) -> T {
    let slot = unsafe { &*(*buf.at(tail)).get() };
    slot.assume_init_read()
}

#[derive(Default)]
pub struct AtomicPair {
    pub curr: AtomicUsize,
    pub next: AtomicUsize,
}