操作系统中的并发控制——使用条件变量同步

本期主题:
操作系统中的并发控制,条件变量


往期链接:

  • linux设备驱动中的并发
  • 操作系统中的多线程问题——原子操作、自旋锁的底层实现
  • 操作系统并发控制——使用互斥锁实现同步

操作系统并发控制之条件变量同步

  • 1. 问题描述
  • 2. 条件变量的API讲解
  • 3. 条件变量来解决上述同步
  • 4. 问题分析及修复


1. 问题描述

参考上一篇文章 操作系统并发控制——使用互斥锁实现同步 的问题,还是这个场景:
典型的同步场景—— 生产者、消费者问题

  • 生产者:生产(任务)资源,放入队列中
  • 消费者:从队列中取出任务来执行

假设这么一个场景:

  1. 生产者任务负责打印 左括号,“(”
  2. 消费者任务负责打印 右括号,“)”
  3. 括号的深度可以变化,例如 3就是代表最多同时3个左括号
  4. 最终打印出来的括号要符合语法,这就需要 先生产再消费(即先打印左括号,再打印右括号)

2. 条件变量的API讲解

条件变量的概念:

  1. 条件变量 用于线程之间的通信。
  2. 一个线程等待某个条件满足,而另一个线程在条件满足时发出信号通知等待的线程继续执行。
  3. 需要结合 互斥锁,以防止多个线程同时修改共享数据。

pthread_cond_wait()

使线程进入等待状态,直到接收到另一个线程发出的条件信号。调用时必须持有互斥锁,并且当该函数被调用时,会自动释放互斥锁,直到线程被唤醒后再重新获取锁。

pthread_cond_signal()

发送信号唤醒等待条件的一个线程。如果有多个线程在等待,只唤醒其中一个。

pthread_cond_broadcast()

唤醒所有等待该条件的线程。

3. 条件变量来解决上述同步

对于生产者任务而言:

  1. 进程进来先拿锁
  2. 拿完锁,判断是否当前有n个左括号,条件满足的话就使用cond_wait(),释放锁并进入休眠,否则打印然后释放锁

对于消费者任务而言:

  1. 进程进来先拿锁
  2. 拿完锁,判断现在左括号是否为0,条件满足的话就使用cond_wait(),释放锁并进入休眠,否则打印然后释放锁

这里用条件变量比上篇文章只用互斥的好处在于:
在这里插入图片描述

看代码:

#include "thread.h"
#include "thread-sync.h"int n, count = 0;
mutex_t lk = MUTEX_INIT();
cond_t cv = COND_INIT();void Tproduce() {while (1) {mutex_lock(&lk);if (count == n) {cond_wait(&cv, &lk);}printf("("); count++;cond_signal(&cv);mutex_unlock(&lk);}
}void Tconsume() {while (1) {mutex_lock(&lk);if (count == 0) {cond_wait(&cv, &lk);}printf(")"); count--;cond_signal(&cv);mutex_unlock(&lk);}
}int main(int argc, char *argv[]) {assert(argc == 2);n = atoi(argv[1]);setbuf(stdout, NULL);for (int i = 0; i < 2; i++) {create(Tproduce);create(Tconsume);}
}

运行结果:
在这里插入图片描述
我们发现有问题

4. 问题分析及修复

在这里插入图片描述
修改方案:

  1. 进入休眠的条件不能只用 if 判断一次,因为不知道是谁唤醒的自己
  2. 条件signal的时候,需要广播,唤醒所有的

改后代码如下:

#include "thread.h"
#include "thread-sync.h"int n, count = 0;
mutex_t lk = MUTEX_INIT();
cond_t cv = COND_INIT();void Tproduce() {while (1) {mutex_lock(&lk);while (count == n) {cond_wait(&cv, &lk);}printf("("); count++;cond_broadcast(&cv);mutex_unlock(&lk);}
}void Tconsume() {while (1) {mutex_lock(&lk);while (count == 0) {cond_wait(&cv, &lk);}printf(")"); count--;cond_broadcast(&cv);mutex_unlock(&lk);}
}int main(int argc, char *argv[]) {assert(argc == 2);n = atoi(argv[1]);setbuf(stdout, NULL);for (int i = 0; i < 2; i++) {create(Tproduce);create(Tconsume);}
}

这样就OK了,测试结果:
在这里插入图片描述

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/55756.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

云栖实录 | Hologres3.0全新升级:一体化实时湖仓平台

本文根据2024云栖大会实录整理而成&#xff0c;演讲信息如下&#xff1a; 演讲人&#xff1a; 姜伟华 | 阿里云智能集团资深技术专家、Hologres 负责人 丁 烨 | 阿里云智能集团产品专家、Hologres 产品负责人 活动&#xff1a; 2024 云栖大会 - 商用大数据计算与分析平台论…

Python中的数据可视化:从入门到进阶

数据可视化是数据分析和科学计算中的重要环节&#xff0c;它通过图形化的方式呈现数据&#xff0c;使复杂的统计信息变得直观易懂。Python提供了多种强大的库来支持数据可视化&#xff0c;如Matplotlib、Seaborn、Plotly等。本文将从基础到进阶&#xff0c;详细介绍如何使用这些…

[单master节点k8s部署]31.ceph分布式存储(二)

Ceph配置 Ceph集群通常是一个独立的存储集群&#xff0c;可以部署在 Kubernetes 集群之外。Ceph 提供分布式存储服务&#xff0c;能够通过 RADOS、CephFS、RBD&#xff08;块存储&#xff09;、和 RGW&#xff08;对象存储&#xff09;等方式与 Kubernetes 集成。即使 Ceph 部…

基于深度学习的手势控制模型

关于深度实战社区 我们是一个深度学习领域的独立工作室。团队成员有&#xff1a;中科大硕士、纽约大学硕士、浙江大学硕士、华东理工博士等&#xff0c;曾在腾讯、百度、德勤等担任算法工程师/产品经理。全网20多万粉丝&#xff0c;拥有2篇国家级人工智能发明专利。 1. 项目简…

Nexpose 6.6.271 发布下载,新增功能概览

Nexpose 6.6.271 for Linux & Windows - 漏洞扫描 Rapid7 Vulnerability Management, release Sep 26, 2024 请访问原文链接&#xff1a;https://sysin.org/blog/nexpose-6/&#xff0c;查看最新版。原创作品&#xff0c;转载请保留出处。 作者主页&#xff1a;sysin.or…

安全工具 | 搭建带有 Web 仪表板的Interact.sh

介绍 Interactsh 是一个用于检测带外交互的开源工具。它是一种旨在检测导致外部交互的漏洞的工具。本文将主要介绍在子域上设置私有 Interact.sh 服务器以及部署其 Web 应用程序。只需一个 AWS EC2 或 VPS 实例和一个域。 要求 •具有静态IP的AWS EC2 / VPS •拥有自己的域…

实例讲解电动汽车VIN写入规则及Simulink建模方法(三)——VIN设置状态反馈及Simulink建模方法

目录 一、整车VIN设置状态反馈规则 二、整车VIN设置状态反馈设置策略 1、VIN设置状态判定 2、VIN设置状态反馈发送 三、整车VIN设置状态反馈Simulink建模 1、VIN设置状态判定 2、VIN设置状态反馈发送 3、整车VIN设置状态反馈设置完整Simulink模型 四、总结 一、整车VI…

Node.js入门——fs、path模块、URL端口号、模块化导入导出、包、npm软件包管理器

Node.js入门 1.介绍 定义&#xff1a;跨平台的JS运行环境&#xff0c;使开发者可以搭建服务器端的JS应用程序作用&#xff1a;使用Node.Js编写服务器端代码Node.js是基于Chrome V8引擎进行封装&#xff0c;Node中没有BOM和DOM 2.fs模块-读写文件 定义&#xff1a;封装了与…

WIFI网速不够是不是光猫的“路由模式”和“桥接模式”配置错了?

光猫&#xff08;光纤调制解调器&#xff09;是一种用于将光纤信号转换为数字信号的设备&#xff0c;通常用于家庭或企业网络中。光猫可以在不同的工作模式下运行&#xff0c;其中最常见的两种模式是“路由模式”和“桥接模式”。以下是这两种模式的详细解释及其优缺点。 一、路…

python发邮件附件:配置SMTP服务器与认证?

python发邮件附件技巧&#xff1f;Python发送多附件邮件的方法&#xff1f; Python作为一种强大的编程语言&#xff0c;提供了丰富的库和工具来实现这一功能。AokSend将深入探讨如何使用Python发邮件附件&#xff0c;并详细介绍配置SMTP服务器与认证的关键步骤。 python发邮件…

通过阿里云Milvus与PAI搭建高效的检索增强对话系统

阿里云Milvus现已无缝集成于阿里云PAI平台&#xff0c;一站式赋能用户构建高性能的RAG&#xff08;Retrieval-Augmented Generation&#xff09;对话系统。您可以利用Milvus作为向量数据的实时存储与检索核心&#xff0c;高效结合PAI和LangChain技术栈&#xff0c;实现从理论到…

第69期 | GPTSecurity周报

GPTSecurity是一个涵盖了前沿学术研究和实践经验分享的社区&#xff0c;集成了生成预训练Transformer&#xff08;GPT&#xff09;、人工智能生成内容&#xff08;AIGC&#xff09;以及大语言模型&#xff08;LLM&#xff09;等安全领域应用的知识。在这里&#xff0c;您可以找…

react 知识点汇总(非常全面)

React 是一个用于构建用户界面的 JavaScript 库&#xff0c;由 Facebook 开发并维护。它的核心理念是“组件化”&#xff0c;即将用户界面拆分为可重用的组件。 React 的组件通常使用 JSX&#xff08;JavaScript XML&#xff09;。JSX 是一种 JavaScript 语法扩展&#xff0c;…

HCIP——GRE和MGRE

目录 VPN GRE GRE环境的搭建 GRE的报文结构 GRE封装和解封装报文的过程 GRE配置​编辑 R1 R2 GRE实验​​​​​​​​编辑 MGRE 原理 MGRE的配置 R1 R2 R3 R4 查看映射表 抓包 MGRE环境下的RIP网络 综合练习​编辑 VPN 说到GRE&#xff0c;我们先来说个大…

Http 协议和 RPC 协议有什么区别?

Http 协议和 RPC 协议有什么区别&#xff1f; 三个层面来述说&#xff1a; 从功能特性来说&#xff1a; HTTP是一个属于应用层的超文本传输协议&#xff0c;是万维网数据通信的基础&#xff0c;主要服务在网页端和服务端的数据传输上。 RPC是一个远程过程调用协议&#xff0…

AI+视频监控:EasyCVR安防平台赋能火电制造行业的视频智能管理方案

随着信息技术的飞速发展和智能制造的深入推进&#xff0c;火电制造行业作为国民经济的重要组成部分&#xff0c;正面临着智能化转型的迫切需求。为了提升生产效率、保障设备安全、优化管理流程&#xff0c;火电制造企业迫切需要引入先进的视频监控与人工智能技术。EasyCVR安防监…

TinyOS 点对基站通信

文章目录 一、前言1.1 发包的BlinkToRadio的数据包格式 二、混淆基站源码分析2.1 Makefile2.2 组件连接2.3 主逻辑代码 一、前言 1.1 发包的BlinkToRadio的数据包格式 如下&#xff0c;注意&#xff1a;AM层类型(1byte)即handlerID使可以在组件中修改的。 二、混淆基站源码…

《安富莱嵌入式周报》第343期:雷电USB4开源示波器正式发布,卓越的模拟前端低噪便携示波器,自带100W电源的便携智能烙铁,NASA航空航天锂电池设计

周报汇总地址&#xff1a;嵌入式周报 - uCOS & uCGUI & emWin & embOS & TouchGFX & ThreadX - 硬汉嵌入式论坛 - Powered by Discuz! 更新一期视频教程 【授人以渔】CMSIS-RTOS V2封装层专题视频&#xff0c;一期视频将常用配置和用法梳理清楚&#xff0…

【Mybatis篇】Mybatis的注解开发

&#x1f9f8;安清h&#xff1a;个人主页 &#x1f3a5;个人专栏&#xff1a;【计算机网络】&#xff0c;【Mybatis篇】 &#x1f6a6;作者简介&#xff1a;一个有趣爱睡觉的intp&#xff0c;期待和更多人分享自己所学知识的真诚大学生。 文章目录 &#x1f3af; Select注解 …

自动猫砂盆有必要买吗?高性价比的自动猫砂盆怎么选通通看这篇

最近市面上又新出了很多款式的自动猫砂盆&#xff0c;有些铲屎官蠢蠢欲动&#xff0c;但又在犹豫&#xff0c;自己真的需要自动猫砂盆吗&#xff1f;作为养猫4年的资深铲屎官&#xff0c;在买过这么多猫咪智能用品的里面&#xff0c;最不后悔的就是自动猫砂盆了&#xff01;要知…