xwrust::xwmd::xwmq

Struct XwmqTx

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

Implementations§

source §

impl<'a, const N: XwSz, T> XwmqTx<'a, N, T>
where [u8; { _ }]: Sized,

source

pub fn eq(&self, data: T) -> XwmqError

等待消息槽，成功后将消息发送到消息队列的尾端（入队）

当消息队列中没有可用的消息槽可用时，发送线程会阻塞等待。
当消息队列中有可用的消息槽时，发送线程被唤醒，并取走一个消息槽，用于发送数据。
消息入队时，会通过 Box 将数据放入heap中，然后进行发送。
当发送线程阻塞等待被中断时，返回 XwmqError::Interrupt 。

§参数说明

data: 类型为 T 的数据

§上下文

线程

§错误码

XwmqError::Ok 没有错误
XwmqError::NotInit 消息队列没有初始化
XwmqError::Interrupt 等待被中断
XwmqError::NotThreadContext 不在线程上下文内
XwmqError::DisPmpt 抢占被关闭
XwmqError::DisBh 中断底半部被关闭
XwmqError::DisIrq 中断被关闭

§示例

extern crate alloc;
use alloc::string::String;
use alloc::string::ToString;

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

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

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
    // ...省略...
    tx.eq("message".to_string());
    // ...省略...
}

source

pub fn eq_to(&self, data: T, to: XwTm) -> XwmqError

限时等待消息槽，成功后将消息发送到消息队列的尾端（入队）

当消息队列中没有可用的消息槽可用时，发送线程会阻塞等待，等待时会指定一个唤醒时间点。
当消息队列中有可用的消息槽时，发送线程被唤醒，并取走一个消息槽，用于发送数据。
消息入队时，会通过 Box 将数据放入heap中，然后进行发送。
当发送线程阻塞等待被中断时，返回 XwmqError::Interrupt 。
当到达指定的唤醒时间点，线程被唤醒，并返回 XwmqError::Timedout 。

§参数说明

data: 类型为 T 的数据
to: 期望唤醒的时间点

§上下文

线程

§错误码

XwmqError::Ok 没有错误
XwmqError::NotInit 消息队列没有初始化
XwmqError::Interrupt 等待被中断
XwmqError::Timedout 等待超时
XwmqError::NotThreadContext 不在线程上下文内
XwmqError::DisPmpt 抢占被关闭
XwmqError::DisBh 中断底半部被关闭
XwmqError::DisIrq 中断被关闭

§示例

extern crate alloc;
use alloc::string::String;
use alloc::string::ToString;

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

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

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
    // ...省略...
    tx.eq_to("message".to_string(), xwtm::ft(xwtm::s(1)));
    // ...省略...
}

source

pub fn eq_unintr(&self, data: T) -> XwmqError

等待消息槽，且等待不可被中断，成功后将消息发送到消息队列的尾端（入队）

当消息队列中没有可用的消息槽可用时，发送线程会阻塞等待。
发送线程的阻塞等待不可被中断。
当消息队列中有可用的消息槽时，发送线程被唤醒，并取走一个消息槽，用于发送数据。
消息入队时，会通过 Box 将数据放入heap中，然后进行发送。

§参数说明

data: 类型为 T 的数据

§上下文

线程

§错误码

XwmqError::Ok 没有错误
XwmqError::NotInit 消息队列没有初始化
XwmqError::NotThreadContext 不在线程上下文内
XwmqError::DisPmpt 抢占被关闭
XwmqError::DisBh 中断底半部被关闭
XwmqError::DisIrq 中断被关闭

§示例

extern crate alloc;
use alloc::string::String;
use alloc::string::ToString;

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

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

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
    // ...省略...
    tx.eq_unintr("message".to_string());
    // ...省略...
}

source

pub fn tryeq(&self, data: T) -> XwmqError

尝试获取消息槽，成功后将消息发送到消息队列的尾端（入队）

当消息队列中没有可用的消息槽可用时，立即返回 XwmqError::NoSlot 。
当消息队列中有可用的消息槽时，取走一个消息槽，用于发送数据。
消息入队时，会通过 Box 将数据放入heap中，然后进行发送。

§参数说明

data: 类型为 T 的数据

§上下文

任意

§错误码

XwmqError::Ok 没有错误
XwmqError::NotInit 消息队列没有初始化
XwmqError::NoSlot 消息队列中没有可用的消息槽

§示例

extern crate alloc;
use alloc::string::String;
use alloc::string::ToString;

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

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

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
    // ...省略...
    tx.tryeq("message".to_string());
    // ...省略...
}

source

pub fn jq(&self, data: T) -> XwmqError

等待消息槽，成功后将消息发送到消息队列的首端（插队）

当消息队列中没有可用的消息槽可用时，发送线程会阻塞等待。
当消息队列中有可用的消息槽时，发送线程被唤醒，并取走一个消息槽，用于发送数据。
消息入队时，会通过 Box 将数据放入heap中，然后进行发送。
当发送线程阻塞等待被中断时，返回 XwmqError::Interrupt 。

§参数说明

data: 类型为 T 的数据

§上下文

线程

§错误码

XwmqError::Ok 没有错误
XwmqError::NotInit 消息队列没有初始化
XwmqError::Interrupt 等待被中断
XwmqError::NotThreadContext 不在线程上下文内
XwmqError::DisPmpt 抢占被关闭
XwmqError::DisBh 中断底半部被关闭
XwmqError::DisIrq 中断被关闭

§示例

extern crate alloc;
use alloc::string::String;
use alloc::string::ToString;

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

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

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
    // ...省略...
    tx.jq("message".to_string());
    // ...省略...
}

source

pub fn jq_to(&self, data: T, to: XwTm) -> XwmqError

限时等待消息槽，成功后将消息发送到消息队列的首端（插队）

当消息队列中没有可用的消息槽可用时，发送线程会阻塞等待，等待时会指定一个唤醒时间点。
当消息队列中有可用的消息槽时，发送线程被唤醒，并取走一个消息槽，用于发送数据。
消息入队时，会通过 Box 将数据放入heap中，然后进行发送。
当发送线程阻塞等待被中断时，返回 XwmqError::Interrupt 。
当到达指定的唤醒时间点，线程被唤醒，并返回 XwmqError::Timedout 。

§参数说明

data: 类型为 T 的数据
to: 期望唤醒的时间点

§上下文

线程

§错误码

XwmqError::Ok 没有错误
XwmqError::NotInit 消息队列没有初始化
XwmqError::Interrupt 等待被中断
XwmqError::Timedout 等待超时
XwmqError::NotThreadContext 不在线程上下文内
XwmqError::DisPmpt 抢占被关闭
XwmqError::DisBh 中断底半部被关闭
XwmqError::DisIrq 中断被关闭

§示例

extern crate alloc;
use alloc::string::String;
use alloc::string::ToString;

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

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

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
    // ...省略...
    tx.jq_to("message".to_string(), xwtm::ft(xwtm::s(1)));
    // ...省略...
}

source

pub fn jq_unintr(&self, data: T) -> XwmqError

等待消息槽，且等待不可被中断，成功后将消息发送到消息队列的首端（插队）

当消息队列中没有可用的消息槽可用时，发送线程会阻塞等待。
发送线程的阻塞等待不可被中断。
当消息队列中有可用的消息槽时，发送线程被唤醒，并取走一个消息槽，用于发送数据。
消息入队时，会通过 Box 将数据放入heap中，然后进行发送。

§参数说明

data: 类型为 T 的数据

§上下文

线程

§错误码

XwmqError::Ok 没有错误
XwmqError::NotInit 消息队列没有初始化
XwmqError::NotThreadContext 不在线程上下文内
XwmqError::DisPmpt 抢占被关闭
XwmqError::DisBh 中断底半部被关闭
XwmqError::DisIrq 中断被关闭

§示例

extern crate alloc;
use alloc::string::String;
use alloc::string::ToString;

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

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

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
    // ...省略...
    tx.jq_unintr("message".to_string());
    // ...省略...
}

source

pub fn tryjq(&self, data: T) -> XwmqError

尝试获取消息槽，成功后将消息发送到消息队列的首端（插队）

当消息队列中没有可用的消息槽可用时，立即返回 XwmqError::NoSlot 。
当消息队列中有可用的消息槽时，取走一个消息槽，用于发送数据。
消息入队时，会通过 Box 将数据放入heap中，然后进行发送。

§参数说明

data: 类型为 T 的数据

§上下文

任意

§错误码

XwmqError::Ok 没有错误
XwmqError::NotInit 消息队列没有初始化
XwmqError::NoSlot 消息队列中没有可用的消息槽

§示例

extern crate alloc;
use alloc::string::String;
use alloc::string::ToString;

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

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

pub fn xwrust_example_xwmq() {
    let (tx, rx) = MQ.init();
    // ...省略...
    tx.tryjq("message".to_string());
    // ...省略...
}