多线程、mutex互斥量

目录

多线程数据共享问题

互斥量

lock()和unlock()

std::lock_guard

死锁

std::lock()

std::lock_guard()的std::adopt_lock参数


多线程数据共享问题

同一个进程中多个线程之间可以共享一部分资源数据。这些对多个线程都大开后门的数据,有些时常会被各个个线程访问。这些不受限制的共享数据,实际上是有一定的风险的。因为多个线程对同一数据的操作往往是不同的,有的读取数据,有的改写数据。这些对数据的改写操作实际上都是分步完成的,也就是说有可能对访问数据改写操作还未完成(已经修改了部分内容),就切换到了另一个线程对其进行读取。这样就会产生数据不一致,数据竞争等问题。

互斥量

为了保护共享数据,避免多个线程同时访问和修改数据导致的数据竞争等问题,就出现了互斥量的概念。互斥量是一把特殊的锁,同一时刻它只能被一个线程持有,其他线程必须等待该线程释放锁后才能获得锁。互斥量(mutex)实际上是个类对象,在使用时应该用include<mutex>将头文件包含进来。线程可以使用lock()函数获取锁,操作完成后再使用unlock()释放锁,这样其他等待锁的线程就可以使用lock(获取锁了,但只有一条线程会获取成功,其他线程将继续等待。

lock()和unlock()

使用互斥量需要手动的调用lock()、unlock()函数确定要保护的代码块。应尽量将保护范围与使用共享数据的范围相吻合。如果保护的范围过广,那么单一执行的代码增多,就会很影响执行效率。如果保护的范围过窄,有些对共享数据的访问未被包含,就不足以保护共享的数据,产生一系列的问题。lock()和unlock()也应确保每一条执行路径都有其对应关系,不要出现lock()后却不unlock()的情况。

以下为示例代码,用于从队列中不断的输入和取出数据:

#include<iostream>
#include<thread>
#include<mutex>
#include<list>
using namespace std;
class A
{
public:
    void inmydata()//线程入口
    {
        for (int i = 0; i < 10000; i++)
        {
            cout << "插入" << i << "数据" << endl;
            mymut.lock();
            mydata.push_back(i);
            mymut.unlock();
        }
    }

    bool func(int& a)
    {
        mymut.lock();
        if (!mydata.empty())//判断是否为空
        {
            a = mydata.front();//读取首元素
            mydata.pop_front();//删除首元素
            mymut.unlock();
            return true;
        }
        mymut.unlock();
        return false;
    }

    void outmydate()//输出线程入口
    {
        int command = 0;
        for (int i = 0; i < 10000; i++)
        {
            bool result = func(command);
            if (result == true) cout << "取出了" << command << "数据" << endl;
            else cout << "取出失败" << endl;
        }
    }


private:
    list<int> mydata;
    mutex mymut;
};
int main()
{
    A a;
    thread newdozer2(&A::outmydate,&a);
    thread newdozer1(&A::inmydata,&a);
   
    newdozer1.join();
    newdozer2.join();
}

std::lock_guard

`std::lock_guard`是C++11中引入的一个模板类,它是用于管理互斥锁(mutex)的RAII(Resource Acquisition Is Initialization)包装器。`std::lock_guard`的主要目的是在多线程环境中自动管理锁的生命周期,避免了手动上锁和解锁。

`std::lock_guard`的使用非常简单,通常在需要保护的代码段前创建一个`std::lock_guard`对象,并将要保护的互斥锁作为参数传递给构造函数。这样,在`std::lock_guard`对象的生命周期内,互斥锁将一直保持锁定状态,确保对共享资源的独占访问。当`std::lock_guard`对象销毁时,互斥锁将被自动解锁,允许其他线程访问共享资源。

mutex my_mytex;
std::lock_guard<std::mutex> myguardlock(my_mutex);

死锁

死锁是并发编程中一种常见现象,通常是由于对资源的竞争,造成了多线程或进程阻塞。这种由于资源竞争造成的僵局,就好像没有钥匙的锁一样,如过没有外力干涉,程序都将停滞不前。例如两条线程同时访问被两个互斥量保护的共享数据,两条线程都分别获得了一把锁,但都因为缺少另一把锁而无法访问共享数据,它们都等待着另一条线程释放锁。这时死锁就发生了。这样的一种矛盾状态导致了两条线程都无法执行。

为了避免死锁,应尽量保证互斥量上锁的顺序一致,这样就能简单有效的避免死锁。

std::lock()

std::lock()用于解决多个互斥量锁头同时锁住的顺序问题。它可以锁住多个互斥量,并确保它们可以同时一起别锁住,从而减少死锁的风险。std::lock()并不管理锁的生命周期,因此还是需要使用互斥量的unlock()成员函数手动释放锁。

#include<iostream>
#include<thread>
#include<list>
#include<mutex>
using namespace std;

std::mutex mymutex1;
std::mutex mymutex2;
list<int> mydata;

void newthread()
    {
        std::lock(mymutex1,mymutex2);
        for(int i=0;i<10000;i++)
            {
                mydata.push_back(i);
            }
        mymutex1.unlock();
        mymutex2.unlock();
    }

int main()
{
    thread mythread1(newthread);
    thread mythread2(newthread);
    mythread1.join();
    mythread2.join();
}

std::lock_guard的std::adopt_lock参数

std::lock()虽然可以避免锁的顺序问题,但仍需要手动的调用互斥量的unlock()解锁。我们可以将std::lock()与std::lock_guand结合使用,先使用std::lock()避免死锁问题,再用std::lock_guard()对象接管std::lock()的锁定状态。为了告诉系统此std::lock_guard是接管锁定状态,而不需要再次锁定互斥量,需要额外该std::lock_guard传递一个参数,就是std::adopt_lock。

现在使用std::lock_guard()和std::adopt_lock()改造上面代码:

#include<iostream>
#include<thread>
#include<list>
#include<mutex>

using namespace std;

std::mutex mymutex1;
std::mutex mymutex2;
list<int> mydata;

void newthread()
{
    std::lock(mymutex1, mymutex2);
    std::lock_guard<std::mutex>(mymutex1, std::adopt_lock);
    std::lock_guard<std::mutex>(mymutex2, std::adopt_lock);
    for (int i = 0; i < 10000; i++)
    {
        mydata.push_back(i);
    }
}

int main()
{
    thread mythread1(newthread);
    thread mythread2(newthread);
    mythread1.join();
    mythread2.join();
}

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

Python程序设计 函数(三)

练习十一 函数 第1关&#xff1a; 一元二次方程的根 定义一个函数qg&#xff0c;输入一元二次方程的系数a,b,c 当判别式大于0&#xff0c;返回1和两个根 当判别式等于0&#xff0c;返回0和两个根 当判别式小于0&#xff0c;访问-1和两个根 在主程序中&#xff0c;根据函数返回…

数据结构(四)—— 堆和二叉树(上)

制作不易&#xff0c;三连支持一下呗&#xff01;&#xff01;&#xff01; 文章目录 前言一、树的概念及结构二、二叉树的概念及结构总结 前言 这篇博客我们将进行更加复杂的一种数据结构的学习——树形结构。 一、树的概念及结构 树是一种非线性的数据结构&#xff0c;它是…

如何把多个文件(夹)平均复制到多个文件夹中

首先&#xff0c;需要用到的这个工具&#xff1a; 度娘网盘 提取码&#xff1a;qwu2 蓝奏云 提取码&#xff1a;2r1z 假定的情况是&#xff0c;共有20个兔兔的图片&#xff0c;想要平均的复制4个文件夹里&#xff0c;那么每个文件夹里面就有5个图片 &#xff08;如果是5个&a…

一般产品:功能、质量、结构

**一般产品&#xff1a;**功能、质量、结构 通用工程&#xff1a; 收益-风险&#xff1b;过程-结果&#xff1b;少数-多数 风险 vs 收益 过程 vs 结果 少数 vs 多数 工程师的特点&#xff1a; 人道无害雇主实事求是&#xff0c;恪守公心&#xff0c;严守纪律&#xff0c;…

信创 | 信创基础设施建设:国内外对比分析研究

信创基础设施建设在国内外的比较分析涉及到多个方面&#xff0c;包括政策支持、产业发展现状、技术进步、市场应用等。通过综合分析&#xff0c;我们可以得出以下结论&#xff1a; 政策支持与发展方向&#xff1a;中国自2019年以来&#xff0c;陆续出台了一系列政策支持信创产业…

RS485空调系统到BACnet江森楼宇系统的高效整合攻略

智慧城市的每一栋建筑都在追求更高的能效与更佳的居住体验&#xff0c;而这一切的实现离不开强大且灵活的楼宇自动化系统。其中&#xff0c;协议转换网关作为连接不同设备的纽带&#xff0c;扮演着至关重要的角色。本文将以一个典型的商业综合体为例&#xff0c;揭秘BACnet协议…

北交所佣金费率标准是多少?北交所相关信息科普

北交所的佣金费率并非固定不变&#xff0c;而是可以根据投资者的需求和证券公司的政策进行调整。目前北交所的佣金费率最低是万分之二。 一般来说&#xff0c;北交所的佣金费率默认在万分之三左右&#xff0c;但这不是固定的费率。根据证券公司的不同&#xff0c;佣金费率可以…

语义分割——前列腺分割数据集

引言 亲爱的读者们&#xff0c;您是否在寻找某个特定的数据集&#xff0c;用于研究或项目实践&#xff1f;欢迎您在评论区留言&#xff0c;或者通过公众号私信告诉我&#xff0c;您想要的数据集的类型主题。小编会竭尽全力为您寻找&#xff0c;并在找到后第一时间与您分享。 …

微服务学习笔记

微服务学习笔记 文章目录 微服务学习笔记认识微服务微服务技术栈微服务学习要点微服务远程调用1)注册RestTemplate2) 服务远程调用RestTemplate Eureka注册中心简介操作过程搭建EurekaServer注册user-service在order-service完成服务拉取 Ribbon负载均衡IRule负载均衡策略饥饿加…

Electron学习笔记(二)

文章目录 相关笔记笔记说明 三、引入现代前端框架1、配置 webpack&#xff08;1&#xff09;安装 webpack 和 electron-webpack&#xff1a;&#xff08;2&#xff09;自定义入口页面 2、引入 Vue&#xff08;1&#xff09;安装 Vue CLI &#xff08;2&#xff09;调试配置 -- …

【Micropython Pitaya Lite教程】烧录固件

文章目录 前言一、编译固件源码二、烧录固件总结 前言 MicroPython是一种精简的Python 3解释器&#xff0c;可以在微控制器和嵌入式系统上运行。Pitaya Lite是一款基于ESP32的微控制器开发板&#xff0c;它结合了低功耗、Wi-Fi和蓝牙功能。结合MicroPython和Pitaya Lite&#…

Python AI库pandas读写数据库的应用操作——以sqlite3为例

Python AI库pandas读写数据库的应用操作——以sqlite3为例 本文默认读者具备以下技能&#xff1a; 熟悉python基础知识&#xff0c;vscode或其它编辑工具 已阅读Pandas基础操作文章,了解pandas常见操作 具备自主扩展学习能力 在数据分析和人工智能领域&#xff0c;pandas库和s…

Ruby中的字符串转换方法

在Ruby中&#xff0c;你可以使用各种方法来转换字符串。下面是一些常用的方法&#xff0c;当然选择哪种适用的方法还得更具具体项目来做调整。日常使用中下面的错误也是比较常见的&#xff0c;看看我们怎么处理哈。 1、问题背景 在Python中&#xff0c;内置的数据结构都有一个…

VMware 虚拟机打开一段时间后卡死,VNX进程CPU占比高

一、问题描述 打开虚拟机后可以正常运行 运行几分钟后突然卡死 然后通过任务管理器可以观察到VMware Workstation VMX应用进程的CPU占比高&#xff0c;CPU也出现异常 关闭虚拟机重新开启&#xff0c;还是一样卡死 二、系统环境 系统: Windows10 VMware: Workstation 17 Pro …

visa/masterCard虚拟信用卡可以用于欧洲亚马逊店Amazon铺吗?欧洲亚马逊Amazon店铺扣租金

亚马逊是网络上最早开始经营电子商务的公司之一&#xff0c;亚马逊成立于1995年&#xff0c;一开始只经营网络的书籍销售业务&#xff0c;现在则扩及了范围相当广的其他产品&#xff0c;已成为全球商品品种最多的网上零售商和全球互联网企业。 很多小伙伴需要开多个站点店铺&a…

软胶囊硬度计:QC部门保障药品质量的精准工具

软胶囊硬度计&#xff1a;QC部门保障药品质量的精准工具 一、引言 随着医药行业的快速发展和药品监管力度的加强&#xff0c;制药企业对于药品质量的要求越来越高。在药品的生产过程中&#xff0c;软胶囊作为一种常见的剂型&#xff0c;其硬度的控制对于药品质量至关重要。软胶…

数组进了多个obj,但是 在修改某个num值时,导致别的num值也发生了变化如何解决?

问题如下&#xff1a; 遇到的问题&#xff0c;数组monthArr1 push进了多个obj,但是 在修改某个num值时&#xff0c;导致别的num值也发生了变化。 而这就是深拷贝浅拷贝的问题。 解决浅拷贝使用深拷贝最简单方法 &#xff1a;JSON.parse(JSON.stringify(obj)) 或者: 使用深拷…

学习Java的日子 Day44 HTML基础

Day44 HTML 学习路线&#xff1a; 前端&#xff1a;展示页面、与用户交互 — HTML 后端&#xff1a;数据的交互和传递 — JavaEE/JavaWeb 1.网页的组成部分(HTMLCSSJavaScript) 前端开发的工作模式&#xff1a;开发输出htmlcssjs HTML&#xff1a;页面结构 CSS&#xff1a;页面…

【linux】——日志分析

1. 日志文件 1.1 日志文件的分类 日志文件&#xff1a; 是用于记录Linux系统中各种运行消息的文件&#xff0c;相当于Linux主机的“日记". 日志文件对于诊断和解决系统中的问题很有帮助&#xff0c;系统一旦出现问题时及时分析日志就会“有据可查”。此外。当主机遭受攻…

JVM的垃圾回收

JVM简介 JVM 是 Java Virtual Machine 的简称&#xff0c;意为 Java虚拟机。 虚拟机:是指通过软件模拟的具有完整硬件功能、运行在一个完全隔离的环境中完整计算机系统 1.JVM的内存区域划分 jvm是一个java进程 每一个java进程就是一个jvm实例 一个进程运行过程中 就要从操作系…