Struct LossyQueue 

pub struct LossyQueue<T> { /* private fields */ }

MPSC wait-free lossy ring buffer.

Implementations

impl<T> LossyQueue<T>

pub fn new(capacity: usize) -> Self

Create a new queue with the given capacity (must be a power of two).

pub fn try_send(&self, item: T) -> Result<(), T>

Worker path — try to enqueue an item.

Uses FAA to claim a slot index, then CAS EMPTY→WRITING as a physical gate. If the slot is occupied (ring buffer lapped or concurrent writer), returns Err(item) immediately — never blocks.

pub fn send_blocking(&self, item: T)

Blocking send for critical commands (Sync, Clear). Spins until the item is successfully enqueued.

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

Daemon path — try to dequeue one item.

Single-consumer: only Daemon ever calls this. Reads from head, returns None if the slot is not yet READY.

Trait Implementations

impl<T> Drop for LossyQueue<T>

fn drop(&mut self)

Executes the destructor for this type.

fn pin_drop(self: Pin<&mut Self>)

🔬This is a nightly-only experimental API. (pin_ergonomics)

Execute the destructor for this type, but different to Drop::drop, it requires self to be pinned.

impl<T: Send> Send for LossyQueue<T>

impl<T: Send> Sync for LossyQueue<T>