4、同步与阻塞：阻塞式消息传递、非阻塞尝试、超时机制

消息传递，说白了就是进程间通信的命脉。但光会发消息还不够，你得懂什么时候该等，什么时候不该等。今天咱们就聊聊这个——同步与阻塞。

我在项目中遇到过不少新手，一上来就写 MsgSend()，结果进程卡死了还不知道怎么回事。嗯，这其实是对阻塞机制理解不够深。咱们今天就把这块彻底讲透。

4.1 阻塞式消息传递：最常用的方式

阻塞式消息传递，是QNX最核心的通信方式。你调用 MsgSend()，发送线程就会挂起，直到接收方处理完并回复。这期间，CPU不会浪费资源去轮询，而是让出时间片给其他线程。

为什么会这样？因为QNX内核知道你在等回复。它会把你的线程放进一个等待队列，等接收方调用 MsgReply() 后，内核再把你唤醒。整个过程，你的线程不占CPU。

我个人习惯，在需要严格同步的场景下，比如传感器数据采集和控制器计算之间，就用阻塞式。简单、可靠、不出错。

// 发送方
int chid = ChannelCreate(0);
int rcvid = MsgSend(pid, &msg, sizeof(msg), &reply, sizeof(reply));
if (rcvid == -1) {
    // 处理错误
}

// 接收方
rcvid = MsgReceive(chid, &msg, sizeof(msg), NULL);
// 处理消息
MsgReply(rcvid, EOK, &reply, sizeof(reply));

你看，代码就这么几行。但要注意，MsgSend() 一旦调用，发送线程就阻塞了。如果接收方一直不回复，发送方就永远卡在那。这就是所谓的「死锁风险」。

4.2 非阻塞尝试：不想等怎么办？

有些场景下，你不想让线程阻塞。比如一个UI线程，如果因为等消息卡住了，界面就无响应了。这时候，非阻塞尝试就派上用场了。

QNX提供了 MsgSendPulse() 和 MsgTrySend() 两种方式。前者是发送脉冲，不等待回复；后者是尝试发送，如果对方没准备好，立即返回错误。

说白了，非阻塞就是「我发了，你爱回不回」。适合那些不需要严格同步的场景，比如日志记录、状态更新。

// 非阻塞发送脉冲
int status = MsgSendPulse(pid, priority, code, value);
if (status == -1) {
    // 发送失败，但不会阻塞
}

// 尝试发送，不阻塞
int rcvid = MsgTrySend(pid, &msg, sizeof(msg), &reply, sizeof(reply));
if (rcvid == -1) {
    // 对方没准备好，立即返回
}

你想想看，MsgTrySend() 返回 -1 时，你该怎么办？我建议你加一个重试逻辑，或者干脆放弃这次发送。千万别在循环里死等，那还不如用阻塞式呢。

4.3 超时机制：给阻塞加个保险

阻塞式虽然好，但万一接收方挂了怎么办？你的线程就永远等下去了。这时候，超时机制就是你的救命稻草。

QNX提供了 MsgSend() 的超时版本——MsgSend() 配合 TimerTimeout() 使用。或者直接用 MsgSend() 的变体，设置一个超时时间。

我个人习惯，在所有可能阻塞的地方都加超时。哪怕超时时间设得很长，也比没有强。你想想看，一个系统里几十个线程，万一有一个卡死，整个系统都可能瘫痪。

// 设置超时
struct sigevent event;
SIGEV_SIGNAL_INIT(&event, SIGALRM);
TimerTimeout(CLOCK_REALTIME, _NTO_TIMEOUT_SEND, &event, &timeout, NULL);

// 发送消息，如果超时则返回错误
int rcvid = MsgSend(pid, &msg, sizeof(msg), &reply, sizeof(reply));
if (rcvid == -1 && errno == ETIMEDOUT) {
    // 超时处理
    printf("消息发送超时！\n");
}

这里要注意，TimerTimeout() 设置的是发送超时。如果超时了，MsgSend() 会返回 -1，errno 设置为 ETIMEDOUT。你可以在超时后重试，或者记录错误日志。

4.4 三种方式的对比

方式	阻塞与否	适用场景	风险
阻塞式	阻塞	严格同步、控制指令	死锁、接收方挂起
非阻塞尝试	不阻塞	日志、状态更新、心跳	消息丢失
超时机制	带超时的阻塞	需要容错的同步通信	超时时间设置不当

你看，三种方式各有优劣。我建议你根据场景灵活选择。比如，在控制系统中，控制指令用阻塞式加超时，状态更新用非阻塞。这样既保证了可靠性，又不会让系统卡死。

4.5 实战中的选择策略

我在项目中总结了一套选择策略，分享给你：

1. 先问自己：这个消息重要吗？重要就用阻塞式加超时，不重要就用非阻塞。
2. 再问：接收方可靠吗？如果接收方可能挂掉，一定要加超时。
3. 最后问：我能接受丢消息吗？能接受就用非阻塞，不能接受就用阻塞式。

你想想看，一个系统里可能有几十个消息通道。如果每个都用阻塞式，万一有一个卡死，整个系统就瘫痪了。所以，我建议你给每个阻塞式调用都加上超时，哪怕超时时间设成10秒。

好了，同步与阻塞这块就讲到这里。记住一句话：阻塞式是基础，非阻塞是补充，超时是保险。三者结合，才能写出健壮的QNX程序。