Struct AtomicStats 

pub struct AtomicStats { /* private fields */ }

Atomic statistics for safe concurrent access

This structure provides lock-free atomic counters for buffer statistics. It can be safely shared between threads without mutexes.

Memory Layout

The structure is cache-line aligned to prevent false sharing.

Thread Safety

All operations are atomic and use relaxed ordering where appropriate.

Implementations

impl AtomicStats

pub const fn new() -> AtomicStats

Create new atomic statistics with all counters set to zero

pub fn record_write(&self)

Record a successful write operation

pub fn record_read(&self)

Record a successful read operation

pub fn record_underflow(&self)

Record an underflow event (read when empty)

pub fn record_overflow(&self)

Record an overflow event (write when full)

pub fn update_peak(&self, current_fill: usize)

Update peak fill level (0-1000 representing 0.0-1.0)

Arguments

• current_fill - Current fill level (0-1000)

This uses a compare-exchange loop to atomically update the peak.

pub fn snapshot(&self) -> BufferStats

Get a consistent snapshot of current statistics

Returns

A BufferStats struct with a snapshot of all counters. Note that the snapshot may not be perfectly consistent due to concurrent updates, but it’s good enough for monitoring.

pub fn reset(&self)

Reset all statistics to zero

Trait Implementations

impl Debug for AtomicStats

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for AtomicStats

fn default() -> AtomicStats

Returns the “default value” for a type.