位置: 编程技术 - 正文

linux中编写自己的并发队列类(Queue 并发阻塞队列)(编写自己的linux系统)

编辑:rootadmin

设计并发队列

上述代码是有效的。但是,请考虑这样的情况:您有一个很长的队列(可能包含超过 , 个元素),而且在代码执行期间的某个时候,从队列中读取数据的线程远远多于添加数据的线程。因为添加和取出数据操作使用相同的互斥锁,所以读取数据的速度会影响写数据的线程访问锁。那么,使用两个锁怎么样?一个锁用于读取操作,另一个用于写操作。给出修改后的 Queue 类。

设计并发阻塞队列

目前,如果读线程试图从没有数据的队列读取数据,仅仅会抛出异常并继续执行。但是,这种做法不总是我们想要的,读线程很可能希望等待(即阻塞自身),直到有数据可用时为止。这种队列称为阻塞的队列。如何让读线程在发现队列是空的之后等待?一种做法是定期轮询队列。但是,因为这种做法不保证队列中有数据可用,它可能会导致浪费大量 CPU 周期。推荐的方法是使用条件变量,即 pthread_cond_t 类型的变量。

并发阻塞队列设计有两个要注意的方面:

1.可以不使用 pthread_cond_broadcast,而是使用 pthread_cond_signal。但是,pthread_cond_signal 会释放至少一个等待条件变量的线程,这个线程不一定是等待时间最长的读线程。尽管使用 pthread_cond_signal 不会损害阻塞队列的功能,但是这可能会导致某些读线程的等待时间过长。

2.可能会出现虚假的线程唤醒。因此,在唤醒读线程之后,要确认列表非空,然后再继续处理。强烈建议使用基于 while 循环的 pop()。

设计有超时限制的并发阻塞队列

在许多系统中,如果无法在特定的时间段内处理新数据,就根本不处理数据了。例如,新闻频道的自动收报机显示来自金融交易所的实时股票行情,它每 n 秒收到一次新数据。如果在 n 秒内无法处理以前的一些数据,就应该丢弃这些数据并显示最新的信息。根据这个概念,我们来看看如何给并发队列的添加和取出操作增加超时限制。这意味着,如果系统无法在指定的时间限制内执行添加和取出操作,就应该根本不执行操作。

设计有大小限制的并发阻塞队列

最后,讨论有大小限制的并发阻塞队列。这种队列与并发阻塞队列相似,但是对队列的大小有限制。在许多内存有限的嵌入式系统中,确实需要有大小限制的队列。对于阻塞队列,只有读线程需要在队列中没有数据时等待。对于有大小限制的阻塞队列,如果队列满了,写线程也需要等待。

要注意的第一点是,这个阻塞队列有两个条件变量而不是一个。如果队列满了,写线程等待 _wcond 条件变量;读线程在从队列中取出数据之后需要通知所有线程。同样,如果队列是空的,读线程等待 _rcond 变量,写线程在把数据插入队列中之后向所有线程发送广播消息。如果在发送广播通知时没有线程在等待 _wcond 或 _rcond,会发生什么?什么也不会发生;系统会忽略这些消息。还要注意,两个条件变量使用相同的互斥锁。

推荐整理分享linux中编写自己的并发队列类(Queue 并发阻塞队列)(编写自己的linux系统),希望有所帮助,仅作参考,欢迎阅读内容。

linux中编写自己的并发队列类(Queue 并发阻塞队列)(编写自己的linux系统)

文章相关热门搜索词:linux怎么编写程序,linux怎么写,linux怎么编写程序,linux系统中怎么编写一个程序,linux编写自己姓名加日期的.c文件,linux怎么编写,linux系统中怎么编写一个程序,linux怎么编写,内容如对您有帮助,希望把文章链接给更多的朋友!

linux多线程编程详解教程(线程通过信号量实现通信代码) 线程分类线程按照其调度者可以分为用户级线程和核心级线程两种。(1)用户级线程用户级线程主要解决的是上下文切换的问题,它的调度算法和调度

Linux进程通信(IPC)方式简介 进程间通信的目的数据传输:一个进程需要将它的数据发送给另一个进程,发送的数据量在一个字节到几兆字节之间。共享数据:多个进程想要操作共

shell监控linux系统进程创建脚本分享 #!/bin/shwhiletruedopsax-ocommand|sort|uniq1.txtusleeppsax-ocommand|sort|uniq2.txtdiff1.txt2.txt|grep'^+[^+]'|whilereadadoa=`echo${a#*+}`if[["$a"!="uniq"]]&&[["$a"!="sort"]]&&[["$a"!=""]]thene

标签: 编写自己的linux系统

本文链接地址:https://www.jiuchutong.com/biancheng/374719.html 转载请保留说明!

上一篇:Linux oracle数据库自动备份自动压缩脚本代码(linux oracle数据库登录)

下一篇:linux多线程编程详解教程(线程通过信号量实现通信代码)(linux多线程编程详解)

  • 私车公用车险是个人名字可报销吗
  • 发票上的收款人复核开票人
  • 如何根据销售额降序排序
  • 费用类科目分类怎么避免出错
  • 其他应付款短期借款
  • 增值税专用发票抵扣期限
  • 冲销应收账款会引起
  • 保证金逾期退还
  • 材料存货的期末计量有何特点
  • 非独立核算不用做核算吗
  • 企业缴纳的社保怎么查询
  • 母子公司之间转让土地使用权
  • 服务费不开发票可以做无票收入吗?
  • 企业的商品产品包括
  • 建筑行业增值税税率是多少
  • 消费税的纳税环节可能有
  • 财税[2016]101
  • 进项税额加计抵扣税收优惠政策
  • 递延收益现金流量附表项目
  • 海关增值税发票双抬头
  • 单位自办食堂为单位职工提供餐饮服务要交增值税吗
  • 社保基数填错了 可以退款吗
  • 一般纳税人增值税结转账务处理
  • win10如何关闭自动修复
  • 蓝屏代码0xc000000f
  • 企业接受捐赠的固定资产账务处理
  • ajax获取php数据
  • 产品生产业务核算工作实训
  • 最贵的一个苹果多少钱
  • php 链式调用
  • 工程物资发生报废损毁
  • 商业零售企业存货非正常损失
  • react的高阶组件理解
  • 嵌入式从业10年,聊聊我对工业互联网和消费物联网的看法 | 文末赠书4本
  • web自动化测试平台
  • web前端面试题目
  • 微信小程序小小驯龙师破解版
  • 增值税发票没认证可以退回吗
  • c++32个关键字详解
  • 小规模纳税人增值税税率
  • 资产负债表的编制原理
  • 金蝶软件怎么录入发票号
  • sqlserver2008无法连接到local用户登录失败
  • 财务报表审计的定义
  • 确认销售收入时不影响应收账款入账金额的是
  • 进项税额转出是借方科目还是贷方科目
  • 凭证字号和凭证编号一样吗
  • 一般纳税人可以开1%的发票吗
  • 支付利息的账务处理
  • 合并报表的内部投资抵消
  • 征收率和税率的区别举例
  • 资产负债表不平最简单的方法
  • sqlserver备份数据库命令
  • sqlserver聚集索引和非聚集索引会不会改变原Id
  • mysql sqlserver语法
  • windows xp搜索功能在哪里
  • vi修改文件
  • 安装win7系统需要注意什么
  • 安装系统需要什么工具
  • windows7快速截图
  • centos6.5安装yum
  • macbook怎样充电
  • 诺基亚安装ngage
  • win7 运行慢
  • 在linux中使用什么可以执行shell脚本
  • cocos2d教程
  • PHP+MySQL+jQuery随意拖动层并即时保存拖动位置实例讲解
  • pythonmatch函数
  • 查看进程pid的命令是
  • jquery滚动到底部
  • jQuery使用contains过滤器实现精确匹配方法详解
  • javascript.
  • 常见python函数
  • javascript页面
  • 税控盘登录密码忘了怎么办怎么重置
  • 广州契税补贴2022政策
  • 劳务派遣服务计税
  • 广东省税务总局局长叫什么名
  • 镇江涨潮退潮时间表
  • 010是哪个市区的电话号码
  • 免责声明:网站部分图片文字素材来源于网络,如有侵权,请及时告知,我们会第一时间删除,谢谢! 邮箱:opceo@qq.com

    鄂ICP备2023003026号

    网站地图: 企业信息 工商信息 财税知识 网络常识 编程技术

    友情链接: 武汉网站建设