当前位置: 首页 > news >正文

linux中posix消息队列的使用记录

        在linux中使用posix中的消息队列时遇到了一个问题,就是在发送消息时,如果队列满了,mq_send接口会一直阻塞,经过查找资料后才发现,该接口默认是阻塞的,也就是说,当队列满了以后,接口会一直等待,一直等到队列中有空间后才返回。

避免阻塞的方式有以下几种:

1、设置为非阻塞模式

在打开队列时,设置指定为O_NONBLOCK的标志,如下所示:

mqd_t mq = mq_open("/myqueue", O_WRONLY | O_CREAT | O_NONBLOCK, 0644, &attr);

如果队列满了,该接口会立即返回-1,errno=11,也就是EAGAIN;

我使用的就是这种方式;

2、使用超时返送函数mq_timedsend(),参考代码如下所示:

#include <mqueue.h>
#include <time.h>struct timespec ts;
clock_gettime(CLOCK_REALTIME, &ts);  // 获取当前时间
ts.tv_sec += 5;  // 设置 5 秒超时int ret = mq_timedsend(mq, msg_ptr, msg_len, msg_prio, &ts);
if (ret == -1) {if (errno == ETIMEDOUT) { /* 处理超时 */ }
}

注意,这个接口中的时间是系统绝对时间,表示相对时间,所以需要先获取当前的系统时间,再加上超时的时间;

这种方式我没有使用,是deepseek提供的方式;

3、增加消息队列容量

这种方式不解决根本问题,队列满了,依然是阻塞;

        有一点儿需要注意,posix的消息队列时系统级的,如果队列满了,也没有消费者去读取队列里面的数据,这个时候,只能重启系统,才能将队列数据清空;

http://www.xdnf.cn/news/1227295.html

相关文章:

  • Cesium性能优化
  • windows系统安装文生图大模型Stable diffusion V3.5 large(完整详细可用教程)
  • 第15讲——微分方程
  • 分类预测 | Matlab实现CPO-PNN冠豪猪算法优化概率神经网络多特征分类预测
  • 操作系统-lecture4(进程的调度)
  • ubuntu22.04系统入门 linux入门(二) 简单命令 多实践以及相关文件管理命令
  • 分布在背侧海马体CA1区域的位置细胞(place cells)对NLP中的深层语义分析的积极影响和启示
  • 设计模式1:创建型模式
  • Java 学习笔记:常用类、String 与日期时间处理
  • 在纯servlet项目中,使用@WebFilter定义了多个filter,如何设置filter的优先级
  • Google机器学习基础(语言模型)
  • Rust在CentOS 6上的移植
  • 梯度下降的基本原理
  • 【Shell脚本自动化编写——报警邮件,检查磁盘,web服务检测】
  • 如何理解推理模型
  • Windows和Linux的tree工具
  • 系统开机时自动执行指令
  • 力扣热题100---------206.反转链表
  • 查看主板信息的3种方法
  • 大模型推理引擎总结
  • 神经网络学习笔记
  • 每日面试题18:基本数据类型和引用数据类型的区别
  • 8.1IO进程线程——文件IO函数
  • Springboot 配置 doris 连接
  • LRU缓存淘汰算法的详细介绍与具体实现
  • VSCode Python 与 C++ 联合调试配置指南
  • 电商项目_性能优化_数据同步
  • Python day31
  • Implement recovery based on PITR using dump file and binlog
  • U-Net vs. 传统CNN:为什么医学图像分割需要跳过连接?