Struct MessageQueue 

pub struct MessageQueue {
    state: Mutex<QueueState>,
    send_waiters: SpinLock<WaitQueue>,
    recv_waiters: SpinLock<WaitQueue>,
    max_bytes: usize,
}

进程间消息队列（支持阻塞的发送/接收）

Fields

state: Mutex<QueueState>

队列状态：消息与当前字节数

send_waiters: SpinLock<WaitQueue>

等待发送（队列满）的进程

recv_waiters: SpinLock<WaitQueue>

等待接收（队列空）的进程

max_bytes: usize

队列的最大容量（字节）

Implementations

impl MessageQueue

pub fn new() -> Self

创建一个新的进程间消息队列

pub fn send(&self, msg: Message)

发送消息（阻塞直到有空间）

pub fn recv(&self) -> Message

接收任意类型的消息（阻塞直到有消息）

pub fn recv_by_type(&self, mtype: i32) -> Message

按类型接收（阻塞直到有匹配类型）

pub fn try_send(&self, msg: Message) -> bool

非阻塞尝试：返回是否成功发送

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

非阻塞尝试接收

pub fn try_recv_by_type(&self, mtype: i32) -> Option<Message>

非阻塞按类型接收

pub fn used_bytes(&self) -> usize

查询当前已用字节数

pub fn set_max_bytes(&mut self, max: usize)

设置最大容量