升级至POSIX消息队列后，如何强制阻塞的mq_receive调用返回？

问题场景 #

正在把消息库从SYSV消息队列升级到POSIX消息队列时碰到了棘手问题：和SYSV队列不同，当mq_receive()处于阻塞状态时，关闭或删除队列无法解除阻塞，直接导致程序挂起。尝试在阻塞后设置O_NONBLOCK标志也毫无作用；而且不能改用mq_timedreceive()或者预先设置O_NONBLOCK——现有应用完全依赖原SYSV队列的阻塞唤醒逻辑。

可行解决办法 #

1. 用信号中断阻塞调用 #

POSIX的mq_receive()属于可中断的系统调用，只要进程/线程收到信号，就会立刻返回-1，同时errno被设为EINTR。具体操作如下：

• 在库内部维护一个阻塞接收当前队列的线程列表，线程进入mq_receive()阻塞前加入列表，退出时移除。
• 当需要关闭或删除队列时，遍历列表给每个线程发送自定义信号（比如SIGUSR1）。
• 设置信号处理函数时不要添加SA_RESTART标志，确保系统调用不会自动重启，mq_receive()会被直接中断返回。
• 线程捕获到EINTR错误后，即可退出阻塞逻辑，配合队列的关闭/删除操作完成资源清理。

2. 发送特殊唤醒消息（无需检测阻塞状态） #

不用纠结如何判断是否有线程阻塞，直接给队列发送一条约定好的特殊消息即可（比如长度为0、固定优先级的消息）：

• 在库的接收逻辑中增加过滤层，一旦收到这个特殊消息，就判定为「唤醒信号」，不向上层应用传递，而是让mq_receive()的调用返回错误或触发退出流程。
• 无论是否有线程阻塞，发送这个消息都不会影响正常业务（只要队列有剩余空间），阻塞的线程会被唤醒处理该特殊消息，非阻塞场景下也能被库内部直接过滤。

3. 利用POSIX消息队列的通知机制 #

通过mq_notify()为队列注册信号或线程通知：

• 可以注册信号通知，当需要唤醒阻塞线程时，主动给队列发一条消息触发通知；或是在删除队列前给通知线程发信号，再由通知线程唤醒阻塞的接收线程。不过这个方法相对复杂，不如前两种直接高效。

注意事项 #

• 信号方案要保证线程安全，维护线程列表时必须加锁，避免并发修改引发问题。
• 特殊消息方案必须在库内部做好过滤，绝对不能让上层应用收到唤醒消息。
• 所有方案都要在库内部封装完成，确保上层应用的调用方式和原SYSV队列完全一致，无需修改现有代码。

内容的提问来源于stack exchange，提问作者Haydentech