Struct AtomicRingBufferMpmc 

pub struct AtomicRingBufferMpmc<T, const N: usize> { /* private fields */ }

Uses atomic’s instead of mutexes

Implementations

impl<T, const N: usize> AtomicRingBufferMpmc<T, N>

pub fn new() -> Arc<Self>

pub fn push(&self, value: T) -> Result<(), T>

pub fn pop(&self) -> Option<T>

pub fn read_head(&self) -> usize

pub fn read_tail(&self) -> usize

pub fn exists(&self, index: usize) -> bool

Trait Implementations

impl<T, const N: usize> Drop for AtomicRingBufferMpmc<T, N>

fn drop(&mut self)

Executes the destructor for this type.

impl<T: Send, const N: usize> Send for AtomicRingBufferMpmc<T, N>

impl<T: Send, const N: usize> Sync for AtomicRingBufferMpmc<T, N>