C++详细讲解互斥量与lock_guard类模板及死锁
更新时间：2022年07月02日 09:22:31 作者：zzsyxl
线程的主要优势在于，能够通过全局变量来共享信息。不过，这种便捷的共享是有代价的：必须确保多个线程不会同时修改同一变量，或者某一线程不会读取正由其他线程修改的变量。为了防止出现线程某甲试图访 问一共享变量时，线程某乙正在对其进行修改。引入了互斥量
保护共享数据，操作时，用代码把共享数据锁住、操作数据、解锁
其他想操作共享数据的线程必须等待解锁、锁定住、操作、解锁
互斥量的基本概念
- 互斥量是个类对象，理解成一把锁，多个线程尝试使用lock()成员函数来枷锁这个锁，是有一个线程可以锁成功，成功的标志是返回
- 如果没有锁成功，那么流程卡在lock这里不断尝试去锁
互斥量的使用
#include <iostream>
#include <string>
#include <thread>
#include <vector>
#include <list>
#include <mutex>
using namespace std;
class A {
public:
//把收到的消息(玩家命令) 入到一个队列的线程
void inMsgRecvQueue()
{
for (int i = 0; i < 1000; i++) {
cout << "inMsgRecvQueue执行，插入一个元素" << i << endl;
my_mutex.lock();
msgRecvQueue.push_back(i);//假设这个数字就是收到的命令
my_mutex.unlock();
}
}
int mesg_lock_func(void)
{
int ret = 0;
my_mutex.lock();
if (!msgRecvQueue.empty()) {
ret = msgRecvQueue.front();//读头部元素
msgRecvQueue.pop_front();//移除头部元素
//处理数据
//cout << "接收到命令，处理命令" << ret << endl;
}
my_mutex.unlock();
return ret;
}
void outMsgRecvQueue()
{
int cmd = 0;
for (int i = 0; i < 1000; i++)
{
cmd = mesg_lock_func();
if (cmd) {
cout << "接收到命令，处理命令" << cmd << endl;
}
else
{
cout << "outMsgRecvQueue执行，但目前消息队列为空" << i << endl;
}
}
}
private:
list<int> msgRecvQueue; //容器，专门用于代表玩家给咱们发送过来的命令
mutex my_mutex;
};lock_guard类模板
为什么此处只有一句 lock_guard sbguard(my_mutex);函数即可 不出问题
lock_guard原理:
lock_guard创建 sbguard(my_mutex);对象，会有构造函数，在构造函数中进行了my_mutex.lock
在函数执行结束后，局部对象会释放，执行析构函数的时候会执行my_mutex.unlock
int mesg_lock_func(void)
{
int ret = 0;
//my_mutex.lock();
lock_guard<mutex> sbguard(my_mutex);
if (!msgRecvQueue.empty()) {
ret = msgRecvQueue.front();//读头部元素
msgRecvQueue.pop_front();//移除头部元素
//处理数据
//cout << "接收到命令，处理命令" << ret << endl;
}
//my_mutex.unlock();
return ret;
}死锁
死锁的条件:
两个线程同时 锁住 两把锁， A线程先锁 锁1，后锁 锁2；B线程先锁 锁2，后锁 锁1，就会发生死锁
class A {
public:
//把收到的消息(玩家命令) 入到一个队列的线程
void inMsgRecvQueue()
{
for (int i = 0; i < 10000; i++) {
cout << "inMsgRecvQueue执行，插入一个元素" << i << endl;
my_mutex1.lock();
my_mutex2.lock();
msgRecvQueue.push_back(i);//假设这个数字就是收到的命令
my_mutex2.unlock();
my_mutex1.unlock();
}
}
int mesg_lock_func(void)
{
int ret = 0;
my_mutex2.lock();
my_mutex1.lock();
//lock_guard<mutex> sbguard(my_mutex);
if (!msgRecvQueue.empty()) {
ret = msgRecvQueue.front();//读头部元素
msgRecvQueue.pop_front();//移除头部元素
//处理数据
//cout << "接收到命令，处理命令" << ret << endl;
}
my_mutex1.unlock();
my_mutex2.unlock();
return ret;
}
void outMsgRecvQueue()
{
int cmd = 0;
for (int i = 0; i < 10000; i++)
{
cmd = mesg_lock_func();
if (cmd) {
cout << "接收到命令，处理命令" << cmd << endl;
}
else
{
cout << "outMsgRecvQueue执行，但目前消息队列为空" << i << endl;
}
}
}
private:
list<int> msgRecvQueue; //容器，专门用于代表玩家给咱们发送过来的命令
mutex my_mutex1;
mutex my_mutex2;
};防止死锁的条件:
两个锁的 锁的顺序必须相同
lock(mutex1, mutex2);
lock_guard sbguard1(my_mutex1,adopt_lock);’
lock与lock_guard的使用
int mesg_lock_func(void)
{
int ret = 0;
lock(my_mutex1, my_mutex2);
lock_guard<mutex> sbguard1(my_mutex1, adopt_lock);
lock_guard<mutex> sbguard2(my_mutex2, adopt_lock);
//lock_guard<mutex> sbguard(my_mutex);
if (!msgRecvQueue.empty()) {
ret = msgRecvQueue.front();//读头部元素
msgRecvQueue.pop_front();//移除头部元素
//处理数据
//cout << "接收到命令，处理命令" << ret << endl;
}
return ret;
}到此这篇关于C++详细讲解互斥量与lock_guard类模板及死锁的文章就介绍到这了,更多相关C++互斥量内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要介绍C语言中的If Else语句怎么使用，在日常操作中，相信很多人在If Else语句怎么使用问题上存在疑惑，小编查阅了各式资料，整理出使用方法，接下来，请跟着小编一起来学习吧2022-06-06![C语言中char*和char[]用法区别分析](//img.jbzj.com/images/xgimg/bcimg1.png)
这篇文章主要介绍了C语言中char*和char[]用法区别,包括使用过程中的误区及注意点分析,需要的朋友可以参考下2014-09-09
这篇文章主要介绍了C语言 扫雷程序的实现的相关资料,需要的朋友可以参考下2017-03-03
这篇文章主要介绍了opencv实现三帧差法的相关资料，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-03-03
这篇文章主要为大家介绍了C语言字符串处理的惊天大坑问题解决，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪2023-05-05
这篇文章主要为大家详细介绍了C++实现动态顺序表，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-05-05
这篇文章主要为大家详细介绍了C语言实现哈夫曼编码，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2020-04-04
这篇文章主要为大家详细介绍了使用mmap实现大文件的复制，单进程与多进程的两种情况，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2019-10-10
这篇文章主要介绍了C++编程中逗号运算符和条件运算符的使用方法讲解,需要的朋友可以参考下2016-01-01
这篇文章主要介绍了C++ 实现汉诺塔的实例详解的相关资料,这里主要说明C++中数据结构的递归的应用，需要的朋友可以参考下2017-08-08
![C语言中char*和char[]用法区别分析](http://img.jbzj.com/images/xgimg/bcimg1.png)
最新评论