Struct ThreadBufferRegistry 

pub struct ThreadBufferRegistry { /* private fields */ }

Lock-free thread buffer registry.

Design

• Fixed-size AtomicPtr array with capacity MAX_THREADS.
• Writer (application thread): atomic fetch_add to claim a slot index, then store the pointer.
• Reader (poller): iterates 0..count, loading each slot’s pointer.
• No Mutex, no heap allocation; registration path is a single atomic operation.

The writer appends once during preallocate() (fetch_add + store), and the reader traverses lock-free during poll(). Zero contention.

Implementations

impl ThreadBufferRegistry

pub const fn new() -> Self

Creates a new empty registry.

pub fn register(&self, thread_buffer: *mut ThreadBuffer)

Registers a ThreadBuffer. Called by the writer side, once per thread.

Internally performs a single fetch_add (claim slot) + a single store (write pointer).

pub fn count(&self) -> usize

Returns the current number of registered slots.

pub fn get(&self, index: usize) -> *mut ThreadBuffer

Loads the pointer at the given slot index. Called by the reader side, lock-free.

Returns null if the slot has not yet been fully written (a very brief window).

pub fn clear_slot(&self, index: usize)

Clears a slot by storing null (called by the poller after reclaiming a ThreadBuffer).

Trait Implementations

impl Default for ThreadBufferRegistry

fn default() -> Self

Returns the “default value” for a type.

impl Sync for ThreadBufferRegistry