Struct InterCoreQueue 

pub struct InterCoreQueue { /* private fields */ }

Cache-line-padded SPSC inter-core message queue.

One instance per (source_core, dest_core) pair. The #[repr(align(64))] ensures that adjacent queue entries in a Vec<InterCoreQueue> do not share a cache line, preventing false sharing between cores that access different pairs.

Uses crossbeam_queue::ArrayQueue for wait-free push/pop. push returns false when the queue is at capacity — callers should treat this as a backpressure signal.

Implementations

impl InterCoreQueue

pub fn new(capacity: usize) -> Self

pub fn push(&self, msg: MailboxMessage) -> bool

Push a message. Returns false if the queue is full.

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

Pop the next message, or None if empty.

pub fn is_empty(&self) -> bool

pub fn len(&self) -> usize

pub fn capacity(&self) -> usize