C++11并发与多线程笔记(5)互斥量概念、用法、死锁演示及解决详解
C++11并发与多线程笔记(5)互斥量概念、用法、死锁演示及解决详解
- 1、互斥量(mutex)的基本概念
- 2、互斥量的用法
- 2.1 lock(),unlock()
- 2.2 lock_guard类模板
- 3、死锁
- 3.1 死锁演示
- 3.2 死锁的一般解决方案:
- 3.3 std::lock()函数模板
- 3.4 std::lock_guard的std::adopt_lock参数
1、互斥量(mutex)的基本概念
- 互斥量就是个类对象,可以理解为一把锁,多个线程尝试用**lock()**成员函数来加锁,只有一个线程能锁定成功,如果没有锁成功,那么流程将卡在lock()这里不断尝试去锁定。
- 互斥量使用要小心,保护数据不多也不少,少了达不到效果,多了影响效率。
2、互斥量的用法
包含#include <mutex>头文件
2.1 lock(),unlock()
步骤如下:
1. 引入头文件
2. 创建一个互斥量
3.在加锁位置:先lock() ,操作共享数据 ,unlock()
注意:lock()和unlock()要成对使用
例1:
#include<iostream>
#include<thread>
#include <vector>
#include<list>
#include<mutex>
using namespace std;class A {
public://把收到的消息(玩家命令)加入到一个队列的线程void inMsgRecvQueue() {for (int i = 0; i < 100000; i++) {cout << "inMsgRecvQueue()执行,插入一个元素 " << i << endl;//cout只输出i,不访问共享数据my_mutex.lock();msgRecvQueue.push_back(i);// 假设这个数字i就是收到的命令,直接弄到消息队列里边来my_mutex.unlock();}}bool outMsgLULProc(int& command) {my_mutex.lock();if (!msgRecvQueue.empty()) {//消息不为空command = msgRecvQueue.front();//返回第一个元素,但不检查元素是否存在msgRecvQueue.pop_front();//移除第一个元素,但不返回my_mutex.unlock();//有分支退出,就要加一个unlock与其对应return true;}my_mutex.unlock();return false;}//把数据从消息队列中取出的线程void outMsgRecvQueue() {int command = 0;for (int i = 0; i < 100000; i++) {bool result = outMsgLULProc(command);if (result == true) {cout << " outMsgRecvQueue()执行,取出一个元素" << command << endl;//可以进行命令(数据)处理}else {//消息队列为空cout << "outMsgRecvQueue()执行,但目前消息队列中为空" << i << endl;}cout << "end" << endl;}}private:list<int> msgRecvQueue;//容器,专门用于存放玩家发来的命令mutex my_mutex;//创建一个互斥量
};int main() {A myobja;//线程通过对象的成员函数时,第二个参数需要是对象的地址,因为成员函数运行时需要用到this指针thread mythreadInMsgRecv(&A::inMsgRecvQueue, &myobja);thread mythreadOutMsgRecv(&A::outMsgRecvQueue, &myobja);mythreadInMsgRecv.join();mythreadOutMsgRecv.join();cout << "I love China!" << endl;return 0;
}
例2:
#include <iostream>
#include <thread>
#include <mutex>
#include <list>
using namespace std;list<int> test_list;
mutex myMutex;//创建互斥量void in_list(){for(int num=0;num<10000;num++){myMutex.lock();cout<<"插入数据: "<<num<<endl;test_list.push_back(num);myMutex.unlock();}}void out_list(){for(int num=0;num<10000; ++num){myMutex.lock();if(!test_list.empty()){int tmp = test_list.front();test_list.pop_front();cout<<"取出数据:"<<tmp<<endl;}myMutex.unlock();}
}
int main()
{thread in_thread(in_list);thread out_thread(out_list);in_thread.join();out_thread.join();cout << "Hello World!" << endl;return 0;
}
2.2 lock_guard类模板
- lock_guard 对象名(myMutex);取代lock()和unlock()
- lock_guard 构造函数执行了mutex::lock();在作用域结束时,调用析构函数,执行mutex::unlock()
- 可以通过添加{}来减小作用域
#include <iostream>
#include <thread>
#include <mutex>
#include <list>
using namespace std;list<int> test_list;
mutex myMutex;void in_list() {for (int num = 0; num < 10000; num++) {{ //也可以多加一对括号,减小作用域lock_guard<mutex> myGuard(myMutex); //创建lock_guard对象cout << "插入数据: " << num << endl;test_list.push_back(num);}}
}void out_list() {for (int num = 0; num < 10000; ++num) {lock_guard<mutex> myGuard(myMutex);if (!test_list.empty()) {int tmp = test_list.front();test_list.pop_front();cout << "取出数据:" << tmp << endl;}}
}
int main()
{thread in_thread(in_list);thread out_thread(out_list);in_thread.join();out_thread.join();cout << "I love China!" << endl;return 0;
}
3、死锁
3.1 死锁演示
死锁至少有两个互斥量mutex1,mutex2。
- 线程A执行时,这个线程先锁 mutex1,并且锁成功了,然后去锁mutex2的时候,出现了上下文切换。
- 上下文切换后,线程B执行,这个线程先锁mutex2,因为mutex2没有被锁,即mutex2可以被锁成功,然后线程B要去锁mutex1.
- 此时,死锁产生了,A锁着mutex1,需要锁mutex2,B锁着mutex2,需要锁mutex1,两个线程没办法继续运行下去。
3.2 死锁的一般解决方案:
只要保证多个互斥量上锁的顺序一样就不会造成死锁。
3.3 std::lock()函数模板
- std::lock(mutex1,mutex2……); 一次锁定多个互斥量(一般这种情况很少),用于处理多个互斥量。
- 如果互斥量中一个没锁住,它就等着,等所有互斥量都锁住,才能继续执行。如果有一个没锁住,就会把已经锁住的释放掉(要么互斥量都锁住,要么都没锁住,防止死锁)
- 破坏请求与保持条件,资源一次性申请,一次性释放
#include <iostream>
#include <thread>
#include <mutex>
#include <list>
using namespace std;list<int> test_list;
mutex myMutex1;
mutex myMutex2;void in_list() {for (int num = 0; num < 10000; num++) {lock(myMutex1, myMutex2);//一次锁定多个互斥量cout << "插入数据: " << num << endl;test_list.push_back(num);myMutex2.unlock();myMutex1.unlock();}
}void out_list() {for (int num = 0; num < 10000; ++num) {lock(myMutex1, myMutex2);if (!test_list.empty()) {int tmp = test_list.front();test_list.pop_front();cout << "取出数据:" << tmp << endl;}myMutex1.unlock();myMutex2.unlock();}
}
int main()
{thread in_thread(in_list);thread out_thread(out_list);in_thread.join();out_thread.join();cout << "I love China!" << endl;return 0;
}
3.4 std::lock_guard的std::adopt_lock参数
采用std::lock函数和std::lock_guard 来联合使用:
- my_guard(my_mutex,std::adopt_lock);
加入adopt_lock后,在调用lock_guard的构造函数时,不再进行lock(); - adopt_guard为结构体对象,起一个标记作用,表示这个互斥量已经lock(),不需要在lock()。
#include <iostream>
#include <thread>
#include <mutex>
#include <list>
using namespace std;list<int> test_list;
mutex myMutex1;
mutex myMutex2;void in_list() {for (int num = 0; num < 10000; num++) {lock(myMutex1, myMutex2); //lock联合lock_guard使用lock_guard<mutex> mutex1(myMutex1, adopt_lock);lock_guard<mutex> mutex2(myMutex2, adopt_lock);cout << "插入数据: " << num << endl;test_list.push_back(num);}
}void out_list() {for (int num = 0; num < 10000; ++num) {lock(myMutex1, myMutex2);lock_guard<mutex> mutex1(myMutex1, adopt_lock);lock_guard<mutex> mutex2(myMutex2, adopt_lock);if (!test_list.empty()) {int tmp = test_list.front();test_list.pop_front();cout << "取出数据:" << tmp << endl;}}
}
int main()
{thread in_thread(in_list);thread out_thread(out_list);in_thread.join();out_thread.join();cout << "I love China!" << endl;return 0;
}
相关文章:
C++11并发与多线程笔记(5)互斥量概念、用法、死锁演示及解决详解
C11并发与多线程笔记(5)互斥量概念、用法、死锁演示及解决详解 1、互斥量(mutex)的基本概念2、互斥量的用法2.1 lock(),unlock()2.2 lock_guard类模板 3、死锁3.1 死锁演示3.2 死锁的一般解决方案:3.3 std:…...

华为云classroom赋能--Devstar使应用开发无需从零开始
华为云DevStar为开发者提供业界主流框架代码初始化能力,通过GUI、API、CLI等多种方式,将按模板生成框架代码的能力推送至用户桌面。同时基于华为云服务资源、成熟的DevOps开发工具链和面向多场景的众多开发模板,提供一站式创建代码仓、自动生…...
软件的数据回滚
原理:所谓的数据回滚,就是数据备份 增量备份: 全量备份: 最简单的事全量备份。 就是spoon工具,完成把所有的表每天定时复制一份,表名“_日期”。 所以有实时表,每日备份表。 回滚就是把之前…...
git clone使用https协议报错OpenSSL SSL_read: Connection was reset, errno 10054
在使用git 下载github上的代码时, 一般有ssh协议和https协议两种。使用ssh协议可以成功clone代码, 但使用https协议时出错: $ git clone https://github.com/openai/improved-diffusion.git Cloning into improved-diffusion... fatal: unab…...

化繁为简,使用Hibernate Validator实现参数校验
前言 在之前的悦享校园的开发中使用了SSM框架,由于当时并没有使用参数参数校验工具,方法的入参判断使用了大量的if else语句,代码十分臃肿,因此最近在重构代码时,将框架改为SpringBoot后,引入了Hibernate V…...
【Qt】多线程
线程创建 自定义线程类 #ifndef CUSTOMETHREAD_H #define CUSTOMETHREAD_H#include <QObject> #include <QThread> #include "add.h"class CustomeThread : public QThread {Q_OBJECT public:// Bind the thread kernel function.explicit CustomeThre…...

腾讯云GPU服务器GN7实例NVIDIA T4 GPU卡
腾讯云GPU服务器GN7实例搭载1颗 NVIDIA T4 GPU,8核32G配置,系统盘为100G 高性能云硬盘,自带5M公网带宽,系统镜像可选Linux和Windows,地域可选广州/上海/北京/新加坡/南京/重庆/成都/首尔/中国香港/德国/东京/曼谷/硅谷…...

3. 爬取自己CSDN博客列表(自动方式)(分页查询)(网站反爬虫策略,需要在代码中添加合适的请求头User-Agent,否则response返回空)
文章目录 步骤打开谷歌浏览器输入网址按F12进入调试界面点击网络,清除历史消息按F5刷新页面找到接口(community/home-api/v1/get-business-list)接口解读 撰写代码获取博客列表先明确返回信息格式json字段解读 Apipost测试接口编写python代码…...

利用HTTP代理实现请求路由
嘿,大家好!作为一名专业的爬虫程序员,我知道构建一个高效的分布式爬虫系统是一个相当复杂的任务。在这个过程中,实现请求的路由是非常关键的。今天,我将和大家分享一些关于如何利用HTTP代理实现请求路由的实用技巧&…...

深度学习(36)—— 图神经网络GNN(1)
深度学习(36)—— 图神经网络GNN(1) 这个系列的所有代码我都会放在git上,欢迎造访 文章目录 深度学习(36)—— 图神经网络GNN(1)1. 基础知识2.使用场景3. 图卷积神经网…...

深入理解JVM——垃圾回收与内存分配机制详细讲解
所谓垃圾回收,也就是要回收已经“死了”的对象。 那我们如何判断哪些对象“存活”,哪些已经“死去”呢? 一、判断对象已死 1、引用计数算法 给对象中添加一个引用计数器,每当有一个地方引用它时,计数器就加一&…...

基于SSH框架实现的管理系统(包含java源码+数据库)
资料下载链接 介绍 基于SSH框架的管理系统 简洁版 ; 实现 登录 、 注册 、 增 、 删 、 改 、 查 ; 可继续完善增加前端、校验、其他功能等; 可作为 SSH(Structs Spring Hibernate)项目 开发练习基础模型…...
图像识别代做服务:实现创新应用的新契机
导言: 随着人工智能和图像处理技术的不断进步,图像识别已经成为了许多领域中的关键应用。然而,图像识别技术的开发和应用往往需要庞大的团队和大量的资源。这就是为什么图像识别代做服务正在崭露头角。本文将探讨图像识别代做服务如何成为实现…...

Coreutils工具包,Windows下使用Linux命令
之前总结过两篇有关【如何在Windows系统下使用Linux的常用命令】的文章: GnuWin32,Windows下使用Linux命令 UnxUtils工具包,Windows下使用Linux命令 今天再推荐一个类似的工具包Coreutils 一、简介 GNU core utilities是GNU操作系统基本…...
神经网络基础-神经网络补充概念-13-python中的广播
概念 在 Python 中,广播(Broadcasting)是一种用于在不同形状的数组之间执行二元操作的机制。广播允许你在不显式复制数据的情况下,对不同形状的数组进行运算。这在处理数组的时候非常有用,尤其是在科学计算、数据分析…...

HDFS原理剖析
一、概述 HDFS是Hadoop的分布式文件系统(Hadoop Distributed File System),实现大规模数据可靠的分布式读写。HDFS针对的使用场景是数据读写具有“一次写,多次读”的特征,而数据“写”操作是顺序写,也就是…...

css学习2(利用id与class修改元素)
1、id选择器可以为标有特定id的html元素指定特定的样式。 2、选择器以#开头,后跟某id的属性值。 3、class选择器用于描述一组元素的样式,class可以在多个元素使用。 4、类选择器用.选择。 5、指定特定的元素使用class。 6、元素的多个类用空格分开&…...
wsl2(debian)安装python的不同版本例如3.8
要在Debian上安装 Python 3.8,可以按照以下步骤操作: 1.确保你的 Debian 系统已经更新到最新版本,可以使用以下命令更新: sudo apt update sudo apt upgrade2.安装 Python 3.8 的依赖项,以及构建 Python 时需要的工具…...
Python教程(9)——Python变量类型列表list的用法介绍
列表操作 创建列表访问列表更改列表元素增加列表元素修改列表元素删除列表元素 删除列表 在Python中,列表(list)是一种有序、可变的数据结构,用于存储多个元素。列表可以包含不同类型的元素,包括整数、浮点数、字符串等…...

springboot+VUE智慧公寓管理系统java web酒店民宿房屋住宿报修信息jsp源代码
本项目为前几天收费帮学妹做的一个项目,Java EE JSP项目,在工作环境中基本使用不到,但是很多学校把这个当作编程入门的项目来做,故分享出本项目供初学者参考。 一、项目描述 springbootVUE智慧公寓管理系统 系统有2权限…...

JavaSec-RCE
简介 RCE(Remote Code Execution),可以分为:命令注入(Command Injection)、代码注入(Code Injection) 代码注入 1.漏洞场景:Groovy代码注入 Groovy是一种基于JVM的动态语言,语法简洁,支持闭包、动态类型和Java互操作性,…...
零门槛NAS搭建:WinNAS如何让普通电脑秒变私有云?
一、核心优势:专为Windows用户设计的极简NAS WinNAS由深圳耘想存储科技开发,是一款收费低廉但功能全面的Windows NAS工具,主打“无学习成本部署” 。与其他NAS软件相比,其优势在于: 无需硬件改造:将任意W…...

微软PowerBI考试 PL300-选择 Power BI 模型框架【附练习数据】
微软PowerBI考试 PL300-选择 Power BI 模型框架 20 多年来,Microsoft 持续对企业商业智能 (BI) 进行大量投资。 Azure Analysis Services (AAS) 和 SQL Server Analysis Services (SSAS) 基于无数企业使用的成熟的 BI 数据建模技术。 同样的技术也是 Power BI 数据…...

visual studio 2022更改主题为深色
visual studio 2022更改主题为深色 点击visual studio 上方的 工具-> 选项 在选项窗口中,选择 环境 -> 常规 ,将其中的颜色主题改成深色 点击确定,更改完成...
五年级数学知识边界总结思考-下册
目录 一、背景二、过程1.观察物体小学五年级下册“观察物体”知识点详解:由来、作用与意义**一、知识点核心内容****二、知识点的由来:从生活实践到数学抽象****三、知识的作用:解决实际问题的工具****四、学习的意义:培养核心素养…...

Python实现prophet 理论及参数优化
文章目录 Prophet理论及模型参数介绍Python代码完整实现prophet 添加外部数据进行模型优化 之前初步学习prophet的时候,写过一篇简单实现,后期随着对该模型的深入研究,本次记录涉及到prophet 的公式以及参数调优,从公式可以更直观…...

Unsafe Fileupload篇补充-木马的详细教程与木马分享(中国蚁剑方式)
在之前的皮卡丘靶场第九期Unsafe Fileupload篇中我们学习了木马的原理并且学了一个简单的木马文件 本期内容是为了更好的为大家解释木马(服务器方面的)的原理,连接,以及各种木马及连接工具的分享 文件木马:https://w…...

sipsak:SIP瑞士军刀!全参数详细教程!Kali Linux教程!
简介 sipsak 是一个面向会话初始协议 (SIP) 应用程序开发人员和管理员的小型命令行工具。它可以用于对 SIP 应用程序和设备进行一些简单的测试。 sipsak 是一款 SIP 压力和诊断实用程序。它通过 sip-uri 向服务器发送 SIP 请求,并检查收到的响应。它以以下模式之一…...
08. C#入门系列【类的基本概念】:开启编程世界的奇妙冒险
C#入门系列【类的基本概念】:开启编程世界的奇妙冒险 嘿,各位编程小白探险家!欢迎来到 C# 的奇幻大陆!今天咱们要深入探索这片大陆上至关重要的 “建筑”—— 类!别害怕,跟着我,保准让你轻松搞…...
LangFlow技术架构分析
🔧 LangFlow 的可视化技术栈 前端节点编辑器 底层框架:基于 (一个现代化的 React 节点绘图库) 功能: 拖拽式构建 LangGraph 状态机 实时连线定义节点依赖关系 可视化调试循环和分支逻辑 与 LangGraph 的深…...