Struct Xwmq

pub struct Xwmq<const N: XwSz, T>
where
    [u8; { _ }]: Sized,
{ /* private fields */ }

消息队列对象结构体

Implementations

impl<const N: XwSz, T> Xwmq<N, T>

where [u8; { _ }]: Sized,

pub const fn new() -> Self

新建消息队列对象

此方法是编译期方法。

示例

• 具有 static 约束的全局变量全局变量：

use xwrust::xwmd::xwmq::*;

static MQ: Xwmq<16, String> = Xwmq::new(); // 16个消息槽，数据类型为String

• 在heap中创建：

extern crate alloc;
use alloc::sync::Arc;

use xwrust::xwmd::xwmq::*;

pub fn xwrust_example_xwmq() {
    let mq: Arc<Xwmq<16, String>> = Arc::new(Xwmq::new()); // 16个消息槽，数据类型为String
}

pub fn init<'a>(&'a self) -> (XwmqTx<'a, N, T>, XwmqRx<'a, N, T>)

初始化消息队列对象

消息队列对象必须调用此方法一次，方可正常使用。 初始化后会返回消息队列的发送者 XwmqTx 以及接收者 XwmqRx 。

示例

use xwrust::xwmd::xwmq::*;

static MQ: Xwmq<16, String> = Xwmq::new();

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
}

Trait Implementations

impl<const N: XwSz, T> Send for Xwmq<N, T>

where [u8; { _ }]: Sized,

impl<const N: XwSz, T> Sync for Xwmq<N, T>

where [u8; { _ }]: Sized,