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++ OpenCV绘制几何图形
这篇文章主要为大家详细介绍了C++ OpenCV绘制几何图形，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-10-10
浅析C++如何跨模块释放内存
这篇文章主要为大家详细介绍了C++中跨模块释放内存的相关知识,文中的示例代码讲解详细,具有一定的借鉴价值,有需要的小伙伴可以了解下
2024-02-02
C++如何实现BCD码和ASCII码的相互转换
这篇文章主要介绍了C++实现BCD码和ASCII码互转，本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2020-06-06
c语言中基于随机函数的使用详解
本篇文章对c语言的随机函数进行了详细的分析介绍。需要的朋友参考下
2013-05-05
用C语言实现简单版9*9扫雷小游戏
这篇文章主要介绍了用C语言实现简单版9*9扫雷小游戏，本文通过实例图文相结合给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
2021-03-03
C语言位图及位图的实现
这篇文章主要为大家详细介绍了C语言位图及位图的实现，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-05-05
C语言实现从指定位置截取文件内容
这篇文章主要为大家详细介绍了如何利用C语言实现从指定位置截取文件内容,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下
2023-11-11
C语言求两个正整数的最大公约数示例代码
在C语言中求两个数的最大公约数是学习循环语句的非常经典的问题,下面这篇文章主要给大家介绍了关于C语言求两个正整数的最大公约数的相关资料,需要的朋友可以参考下
2021-12-12
一文教你快速了解C语言中的作用域和常量
作用域(scope)是程序设计概念,通常来说一段程序代码中所用到的名字并不总是有效/可用,下面这篇文章主要给大家介绍了关于如何快速了解C语言中的作用域和常量的相关资料,需要的朋友可以参考下
2023-06-06
Qt编写地图实现省市区域图的示例代码
本文主要介绍了Qt编写地图实现省市区域图的示例代码，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2021-12-12