消息队列超时机制：超时参数设置与阻塞/非阻塞行为

消息队列的超时机制，说白了就是等多久的问题。我刚开始接触VxWorks时，觉得这玩意儿很简单——等不到就等呗。后来在项目中吃过亏，才发现这里面的门道真不少。

今天咱们就聊聊超时参数怎么设，阻塞和非阻塞到底怎么选。嗯，这里要注意，选错了轻则任务卡死，重则系统崩溃。

一、超时参数的本质

VxWorks的消息队列API里，超时参数通常叫timeout，单位是tick。你可能会问：为什么不用毫秒？

其实VxWorks内核调度是基于tick的。一个tick默认是1毫秒，但你可以通过sysClkRateSet()改。我个人习惯把tick设成10毫秒，这样系统开销小一些。

超时参数有三个特殊值：

• WAIT_FOREVER（-1）：死等，直到拿到消息
• NO_WAIT（0）：不等，立即返回
• 正数：等待指定的tick数

二、阻塞行为详解

阻塞模式，就是任务在等消息时被挂起。这时候CPU会去干别的活儿，不浪费。

看个例子：

MSG_Q_ID msgQId;
char buffer[100];

/* 创建消息队列 */
msgQId = msgQCreate(10, sizeof(buffer), MSG_Q_PRIORITY);

/* 阻塞等待消息，最多等100个tick */
if (msgQReceive(msgQId, buffer, sizeof(buffer), 100) == ERROR) {
    if (errno == S_objLib_TIMEOUT) {
        printf("超时了，没等到消息\n");
    } else {
        printf("其他错误\n");
    }
}

我在项目中遇到过一个问题：某个任务用WAIT_FOREVER等消息，结果发送端挂了，这个任务就永远卡在那了。你想想看，系统里有个僵尸任务，多可怕。

三、非阻塞行为详解

非阻塞模式，就是不管有没有消息，函数立即返回。说白了就是「问一下，有就有，没有拉倒」。

/* 非阻塞接收 */
if (msgQReceive(msgQId, buffer, sizeof(buffer), NO_WAIT) == ERROR) {
    if (errno == S_objLib_TIMEOUT) {
        printf("队列为空，不等待\n");
    }
}

非阻塞模式适合用在轮询场景。比如一个监控任务，每隔一段时间检查一下有没有新消息，没有就继续干别的。

我记得有个项目做数据采集，用非阻塞模式轮询多个消息队列。这样每个队列都能照顾到，不会因为一个队列没消息就卡死。

四、超时参数设置策略

怎么设超时？我总结了几条经验：

场景	推荐超时	理由
关键控制指令	WAIT_FOREVER	必须等到，否则系统异常
周期性数据	周期的一半	避免错过下一个周期
调试信息	NO_WAIT	可有可无，不耽误正事
外部设备响应	100-500 tick	设备响应通常有上限

五、阻塞与非阻塞的选择

选阻塞还是非阻塞？我个人的经验是：

• 高优先级任务：用阻塞。等消息时让出CPU，不浪费。
• 低优先级任务：用非阻塞或短超时。避免被高优先级任务饿死。
• 中断服务程序：只能用非阻塞。中断里不能挂起。
• 初始化阶段：用阻塞。系统刚启动，等消息是合理的。

你想想看，如果一个低优先级任务用WAIT_FOREVER等消息，而发送消息的是个高优先级任务，那这个低优先级任务可能永远等不到——因为高优先级任务一直在跑，没机会发消息。

六、避坑指南

我曾经踩过几个坑，分享给你：

• 坑一：超时时间太短。系统负载高时，消息可能延迟。设个50 tick的超时，结果系统忙的时候要80 tick才能响应。嗯，这时候就会误判为超时。
• 坑二：忘记检查返回值。很多人只检查ERROR，不检查errno。其实超时和队列满都是ERROR，但处理方式完全不同。
• 坑三：多个任务等同一个队列。VxWorks默认只支持一个任务阻塞在接收端。多个任务同时等，只有一个能拿到消息，其他的会一直等。

七、实际应用场景

说个我实际用过的例子。一个数据采集系统，有传感器任务、处理任务、存储任务：

/* 传感器任务 - 非阻塞发送 */
void sensorTask(void) {
    while (1) {
        data = readSensor();
        /* 非阻塞发送，队列满了就丢弃 */
        if (msgQSend(dataQueue, &data, sizeof(data), NO_WAIT) == ERROR) {
            logMsg("数据丢失\n", 0,0,0,0,0);
        }
        taskDelay(10);  /* 10 tick采集一次 */
    }
}

/* 处理任务 - 阻塞接收 */
void processTask(void) {
    while (1) {
        /* 等数据，最多等50 tick */
        if (msgQReceive(dataQueue, &data, sizeof(data), 50) == OK) {
            processData(&data);
        } else {
            /* 没数据就做点别的 */
            doHousekeeping();
        }
    }
}

这个设计里，传感器任务用非阻塞发送，保证不会因为队列满而卡住。处理任务用带超时的阻塞接收，既不会死等，也不会空转。

好了，超时机制就聊到这。记住一句话：超时参数不是随便设的，要根据实际场景来。多测试、多观察，才能找到最合适的值。