【Linux系统编程二十七】:线程的互斥与同步(互斥锁的使用与应用)

news2024/11/16 6:56:23

【Linux系统编程二十七】:线程的互斥与同步(互斥锁的使用与应用)

  • 一.问题:数据不一致(混乱/不安全)
    • 1.多线程并发计算不安全
    • 2.将数据加载到寄存器的本质
  • 二.解决方法--互斥锁
  • 三.互斥锁的概念与接口
    • 1.定义锁
    • 2.加锁/解锁
  • 四.互斥锁实现原理与应用
    • 1.原理:exchange指令
    • 2.应用:同步场景
    • 3.应用:封装锁
  • 五.存在问题:死锁

一.问题:数据不一致(混乱/不安全)

在线程中,全局变量就相当于一个共享资源,每个线程都可以看到,并且每个线程都可以访问,一旦多线程访问这个共享资源,就可能会出现一些问题。
会出现什么问题呢?为什么会出现问题呢?如何解决问题呢?
首先多线程访问共享资源,通常会出现数据不一致问题。为什么会出现呢?

在这里插入图片描述
我们以上面的模拟抢票过程来简述:

1.多线程并发计算不安全

多线程并发去计算的过程是不安全的,为什么呢?因为计算的过程就是不安全的。最简单的计算比如++,–,在代码层面只是简单的一行,但在编码层面它会转成3句汇编。

计算机中–计算的过程是被分成3步的:
1.首先会将变量从内存读入到cpu的寄存器中。
2.然后在CPU的内部进行–计算
3.将计算结果再写回内存。
在这里插入图片描述

而–计算被分成3步的话,那么就会存在一个线程计算一半中,然后被切换走的场景。这个计算过程是不安全的,因为还没计算完,就被切换走了。
而我们知道,线程被切换走时,不仅要将PCB给带走,还需要将硬件上下文保存带走。线程上下文中保存的就是上次的数据,这些数据从哪里来的?是寄存器中的!

2.将数据加载到寄存器的本质

线程在执行计算的时候,将共享资源从内存加载到寄存器中,然后进行运算,如果突然该线程被切换走了,那么该线程就要拿着它的PCB和硬件上下文滚蛋。新线程将自己的数据放到CPU的寄存器中,当运行一段时间后,老线程又被唤醒,老线程首先做的是将自己的上下文恢复到CPU上,然后再进行计算。
而线程的上下文中的数据都是从寄存器中获取的。所以线程将共享资源从内存加载到寄存器的本质就是:将数据的内容,变成自己的上下文,也就是以拷贝的方式,给自己拿了一份,不然被切换走了,下次回来怎么恢复数据呢?

所以多线程并发计算的过程是不安全的,会导致数据不一致。

场景1:多线程并发计算
比如一个线程正在计算一个变量1000,要将做–计算。该线程刚把数据从内存中加载到寄存器中,还没来得及计算,就被切换走了,走的时候线程上下文带走了。
然后线程2就被调度起来进行运算,他很幸运,一直在执行着–的三步骤,循环了990次,在991次时,刚将变量10从内存加载到cpu寄存器时,就被切换了,原来的线程被唤醒,该线程被唤醒后第一步做的就是将上下文恢复到寄存器里,也就是将原来的数据1000又恢复到寄存器上了,然后该线程就开始执行运算,这就导致了数据不一致问题了!
在这里插入图片描述


多线程并发计算的过程是不安全的,还会导致数据不安全。
在这里插入图片描述

场景2:多线程并发比较(比较也是属于计算)
比较是逻辑运算,需要加载到CPU中
我们想要变量小于0时就不要–了,大于0时再去减减。但多线程并发执行时,结果却不是这样的。
最后的结果都减到负数却还在减减计算。这是为什么呢?
就是因为多线程并发访问共享资源造成的,比如最后变量ticket为1了,3个线程同时比较变量,也就是同时将变量从内存加载到寄存器上(而这个过程本质就是将数据拷贝到线程自己的上下文中),然后还没开始进行比较,其中2个线程被切换,只有一个线程在运行,这三个被切换掉的线程的上下文中都保存着相同的数据1,而真正执行的线程发现该变量满足条件,就继续减减了,最后变量变成0。下一次,三个被切换的线程同时被唤醒,第一步就是将自己的上下文恢复到寄存器中,这是寄存器中的数据就是1,然后CPU比较发现这三个线程都满足计算条件,就都进行减减计算了,所以数据就从0减到1减到2,最后减到3。这就是多线程并发访问导致的后果。
在这里插入图片描述


场景3:多执行流并发打印,显示屏上显示混乱
因为对于多线程来说,往显示屏上打印,就是一个往一个文件里写入,这个文件就相当于共享资源,它们都可以使用,一起使用的后果就是数据混乱打印,无序,信息交叉
在这里插入图片描述

也就是将这个共享资源保护起来,让它具备原子性。

二.解决方法–互斥锁

导致上面数据不一致问题的根本在于多线程并发访问,所以不要让多线程并发访问就可以解决问题,而这样的解决概念我们称为互斥,就是在任何时刻,只允许一个执行流访问共享资源的行为,我们称为互斥。而如何实现互斥呢?我们是根据锁来实现的,使用锁,我们就可以保证执行流在访问共享资源时,只有一个执行流能够访问,等该执行流访问完后,其他执行流才可以接着访问。

概念---->对共享资源的任何访问,保证任何时候只有一个执行流访问—互斥
实现方法—>锁

三.互斥锁的概念与接口

锁的出现是为了实现线程之间互斥。而互斥也是具有范围的,并不是线程所有部分都要互斥,只是针对共享资源线程之间互斥,在任何时刻只允许一个执行流访问的资源就叫做临界资源。也就是只有对共享资源做了保护,它才叫做临界资源。而访问临界资源的那部分代码就被称为临界区。
加锁的本质就是对共享资源保护,让它变成临界资源,让线程在临界区只能串联的形式执行。不能并发执行。
而且一旦加锁,可能会较低线程的并发度,所以我们的加锁有一个原则:尽量要保证临界区代码要越少越好。(毕竟线程发明出来就是为了调高并发度)
在这里插入图片描述

1.定义锁

在内核中,库给我们提供了锁的数据类型pthread_mutex_t
在这里插入图片描述

定义一把锁,有两种方式,要么定义成局部锁,要么定义成全局锁。
定义成局部锁,就需要对锁来初始化和销毁。
而定义成全局锁,只需要赋值一个宏,就可以完成定义和初始化了。
在这里插入图片描述

2.加锁/解锁

在这里插入图片描述
将锁定义好后,就可以对资源进行加锁了,在共享资源的前面加锁,最后面解锁,这样就相当于对共享资源加锁了。
加锁使用lock,解锁使用unlock,参数就是对应的锁地址。
在这里插入图片描述

共享资源一旦被加锁了,执行流要想访问该临界资源,就需要申请锁,只有申请到锁了,才可以访问临界资源,往后执行,而锁资源只有一把,一旦被申请走了,其他线程就无法申请到了,只能阻塞等待锁资源就绪。
在这里插入图片描述
加锁后,互斥锁就会对临界区进行保护。
【问题1】请简述什么是线程互斥,为什么需要互斥

线程互斥指的是在多个线程间对临界资源进行争抢访问时有可能会造成数据二义,因此通过保证同一时间只有一个线程能够访问临界资源的方式实现线程对临界资源的访问安全性

【问题2】加完锁后,在临界区中,线程可以被切换吗?

可以的!线程虽然被切换走了,但它是持有锁被切换走的,锁也被带走了,这块临界资源其他线程还是不能访问的。
通过加锁,就能保证当前线程在访问临界区期间,对于其他线程来说是原子的。谁持有锁,访问它的过程就是原子的。
其他线程不关心你拿到锁干了什么,只关心你拿没拿到锁,或者释放没释放锁。
在这里插入图片描述

四.互斥锁实现原理与应用

我们通过锁来保护了共享资源,让它不会被多线程并发访问。线程只有获取锁资源,才能访问临界资源,那么对于锁来说,它不也是一个共享资源吗?它来保护临界资源,那么谁来保护它呢?

不用担心,申请锁和释放锁,本身就是原子的,不会被中断,要么执行完,要么不执行。它本身就被设计成了原子性操作,那么这是如何做到的呢?
在这里插入图片描述

1.原理:exchange指令

在这里插入图片描述
加锁的底层逻辑:

在这里插入图片描述

将0放在al这个寄存器中,然后到内存中用al与mutex变量互相交换。al中就获取到锁资源,而内存中的mutex就变成0了。

锁本身就是一个变量,在访问它时,需要将它从内存读取到cpu的寄存器上,而这一个过程本质就是将该数据的内容拷贝到线程的硬件上下文中。这里不是单纯的读取,而是使用交换exchange指令,将内存中的数据交换到cpu的寄存器中。也就是将数据交换到线程的硬件上下文中。
在这里插入图片描述

因为共享资源就只有一个,一旦交换完,就属于线程私有的了,为什么这么说呢?

因为每个线程的上下文都是独立私有的,你将锁资源交换从内存交换出来,变成自己的上下文内容,而锁资源只有一份,内存给你一个锁资源,你给内存一个0,其他线程如果想再从内存中交换,只能交换到0,而不能交换到锁资源了。

这里是引用在这里插入图片描述

解锁底层逻辑:
在这里插入图片描述

2.应用:同步场景

在很多场景下需要使用互斥,而互斥有时候并不能完全解决好问题,就比如同步问题。其实互斥是一种解决方案,它也是有局限性的,在某些场景下,我们需要在互斥的基础上再应用同步,才能解决问题。
那么什么叫同步呢?
就是让所有的线程按照一定的顺序来获取资源的行为,叫做同步。同步是在互斥的基础上进行的。
是什么问题导致需要同步来解决呢?
就比如我们的抢票程序中存在一个细节,我们创建了3个线程来共同抢票,因为多线程并发抢票会出现问题,所以我们给共享资源加锁保护,让线程之间互斥,理论上应该是这三个线程轮次抢票,但程序跑起来后,却不是这样:是线程1一直在抢票,其他两个线程没有在抢票,这是为什么呢?

#include <iostream>
#include <unistd.h>
#include <pthread.h>
#include <vector>
#include "LockGuard.hpp"
using namespace std;

#define NUM 4 // 创建多线程

//定义全局锁
//方式定义并且初始化
pthread_mutex_t lock=PTHREAD_MUTEX_INITIALIZER;
class threadData
{
public:
    threadData(int number)
    {
        _threadname = "thread-" + to_string(number);
    }

public:
    string _threadname;
};
int ticket=1000;//全局变量,共享资源
void * Getticket(void* args)
{

    threadData *td=static_cast<threadData*>(args);//可以知道是哪一个线程执行的
    const char* name=td->_threadname.c_str();
    //线程持续抢票
    while(true)
    {
        //加锁,锁共享资源,即临界区
      
        pthread_mutex_lock(&lock);//线程申请成功锁后,才能往后执行,其他没有锁的线程就会在阻塞挂起
        if(ticket>0)
        {
            usleep(1000);//增加其他进程调度的机会
            printf("%s, get a ticket: %d\n",name,ticket);
            ticket--;
            pthread_mutex_unlock(&lock);//解锁
        }
        else 
        {
            pthread_mutex_unlock(&lock);
            break;
        }
        
        //usleep(15);//强完票,我们还需要做一些事情,不是抢完立即再去强实多线程还要执行得到票之后的后续动作
    }
    printf("%s ...quit\n",name);
    return nullptr;
}
//多线程并发执行会存在问题----数据不一致问题
//如何解决呢?-->互斥锁,将共享资源加锁起来,不许多执行流一起访问

int main()
{
    // 1.如何创建多线程呢?--创建多线程,主线程要想找到每个线程,就需要保存每个线程的tid,用vector保存
    // 主线程在创建多线程之前,给每个线程都初始些属性,比如名字等
    vector<pthread_t> vp;//存储每个线程的tid
    vector<threadData*> vtd;//存储每个线程的基本属性--名字
    
    for (int i = 0; i < NUM; i++)//同时创建了四个线程,这四个线程都会执行GEtticket
    {
       
        pthread_t tid;
        threadData *td = new threadData(i);
        vtd.push_back(td);
        pthread_create(&tid, nullptr, Getticket,vtd[i]);
        vp.push_back(tid);
    }
    
     //多线程创建完,主线程还需要等待这些多线程,根据线程的tid等待
     for(int i=0;i<vp.size();i++)
     {
         pthread_join(vp[i],nullptr);
     }

     //还需要释放申请的资源
     for(int i=0;i<vtd.size();i++)
     {
        delete vtd[i];
     }

     return 0;
}

在这里插入图片描述

这里就存在一个事实:不同线程对于锁资源的竞争能力可能会不同,有的线程因为竞争能力很强,会一直抢到锁资源,然后执行后面的代码,释放锁资源,然后又抢到锁资源,执行代码,释放锁资源…….

比如说当前线程1距离锁最近,在持有锁阶段,其他线程还在挂起,当线程1刚释放锁资源时,其他线程还需要被唤醒,而线程1直接就可以获取到,所以竞争能力很强。

而其他线程由于长时间不能获取到锁资源就会导致饥饿问题。

1.所以在纯互斥环境下,如果锁资源分配不够合理,就容易出现其他线程饥饿问题。
2.但并不是说只要有互斥就会存在饥饿,更不是说互斥不好,而是在适合纯互斥的场景下去用互斥。

所以这里我们就可以利用同步来解决问题,问题根源就是因为线程1刚把锁释放,就又去申请锁,所以我们让线程1在把锁释放之后,不要再去申请锁,而是去一个队列里去排队,这样其他线程就会有机会来获取锁资源,然后执行代码,释放锁资源后,也去队列里排队,这样就能保证每个线程都可以获取锁资源。

其实这里是代码方面存在一些问题,在抢票之后,不应该立即再去抢票,应该需要做一些动作的,比如买完票后,需要将自己的身份信息核对等等,所以我们这里休眠一会代替执行一些动作。有了这个时间间隙,线程之间切换的几率就会大大提高。在这里插入图片描述
在这里插入图片描述

3.应用:封装锁

我们可以将加锁,解锁等动作再封装简单点

#pragma once

#include <pthread.h>


class LockGuard
{
public:
    LockGuard(pthread_mutex_t *lock):_lock(lock)
    {
pthread_mutex_lock(_lock);//加锁                                                                                                                                                                               NNNNNNNNNNNNNNNNNNNNNNNNN NN N N NN N  NNNNNNNNNNNNNNNNNNNNNNNN                                                                                                                                                                                                                                                                          ngmNMN N N N N MN  
    }
     
    ~LockGuard()
    {
        pthread_mutex_unlock(_lock);//解锁
    }
private:
   pthread_mutex_t *_lock;
};

要注意,这里并没有封装真正的锁,而是锁的指针,锁的定义需要外界传进来初始化。
在这里插入图片描述

五.存在问题:死锁

加锁也会存在问题,那就是死锁。
什么叫死锁呢?就是你当前拥有一把锁,然后又去申请别人的锁资源,别人也申请你的锁资源,你们两都不释放锁资源,就造成闭环死锁。

这是存在多把锁的情况,而只有一把锁,也会存在死锁,那就是你当前拥有锁,然后又去申请锁资源,就会申请失败,然后被挂起,但你挂起的线程是持有锁的,所以其他线程也无法申请锁,都会失败。

在这里插入图片描述
那么如何解决死锁问题呢?破坏形成死锁的必要条件!

在这里插入图片描述

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

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

相关文章

AArch64 Exception Model学习

提示 该博客主要为个人学习&#xff0c;通过阅读官网手册整理而来&#xff08;个人觉得阅读官网的英文文档非常有助于理解各个IP特性&#xff09;。若有不对之处请参考参考文档&#xff0c;以官网文档为准。 1 Privilege and Exception Levels 1.1 为什么要划分权限&#xf…

swaggerUI不好用,试试这个openapiUI?

title: swaggerUI不好用&#xff0c;试试这个openapiUI? date: 2024-01-08 categories: [tool] tags: [openapi,工具] description: 基于swaggger2, openapi3规范的UI文档 1.背景 由于长期使用 swaggerUI 工具&#xff0c;它的轻量风格个人觉得还是不错的&#xff0c;但是它…

npm v10.2.4 is known not to run on Node.js v14.16.1.

报错&#xff1a; ERROR: npm v10.2.1 is known not to run on Node.js v10.24.1. This version of npm supports the following node versions: ^18.17.0 || >20.5.0. You can find the latest version at https://nodejs.org/. 这种情况降级npm&#xff0c;降不了&…

目标检测-One Stage-YOLOv6

文章目录 前言一、YOLOv6的网络结构和流程二、YOLOv6的创新点总结 前言 YOLOv6 是美团视觉智能部研发的一款目标检测框架&#xff0c;致力于工业应用。论文题目是《YOLOv6: A Single-Stage Object Detection Framework for Industrial Applications》。 和YOLOv4、YOLOv5等不…

Linux——firewalld防火墙(一)

一、Linux防火墙基础 Linux 的防火墙体系主要工作在网络层.针对TCP/P数据包实时过滤和限制.属于典型的包过滤防火墙&#xff08;或称为网络层防火墙)。Linux系统的防火墙体系基于内核编码实现&#xff0e;具有非常稳定的性能和高效率,也因此获得广泛的应用.在CentOS 7系统中几种…

虾皮如何查看自己的店铺

在虾皮&#xff08;Shopee&#xff09;平台上查看自己的店铺是非常重要的&#xff0c;因为它可以帮助您了解店铺的运营情况、管理商品和处理客户服务等。下面是在虾皮平台上查看店铺的步骤&#xff1a; 先给大家推荐一款shopee知虾数据运营工具知虾免费体验地址&#xff08;复制…

【leetcode 447. 回旋镖的数量】审慎思考与推倒重来

447. 回旋镖的数量 题目描述 给定平面上 **n **对 互不相同 的点 points &#xff0c;其中 points[i] [xi, yi] 。回旋镖 是由点 (i, j, k) 表示的元组 &#xff0c;其中 i 和 j 之间的距离和 i 和 k 之间的欧式距离相等&#xff08;需要考虑元组的顺序&#xff09;。 返回平…

remote-ssh如何离线下载历史版本

remote-ssh离线下载任意历史版本方法&#xff0c;简单有效 很多小伙伴都会遇到这样的问题&#xff0c;由于内网服务器中安装的vs code版本较低&#xff0c;比如1.62.0版本&#xff0c;官网发布的version history 只展示最新的五个版本&#xff0c;还是太高了&#xff0c;导致下…

C#,入门教程(12)——数组及数组使用的基础知识

上一篇&#xff1a; C#&#xff0c;入门教程(11)——枚举&#xff08;Enum&#xff09;的基础知识和高级应用https://blog.csdn.net/beijinghorn/article/details/123917587 数组是一种数据集合&#xff0c;是一组完全相同的、按顺序存放的数据。 需要记住数组的几个特征&…

P1003 [NOIP2011 提高组] 铺地毯————C

目录 [NOIP2011 提高组] 铺地毯题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 样例 #2样例输入 #2样例输出 #2 提示 解题思路Code运行结果 [NOIP2011 提高组] 铺地毯 题目描述 为了准备一个独特的颁奖典礼&#xff0c;组织者在会场的一片矩形区域&#xff08;可看做…

MT6785安卓核心板_联发科MTK6785/Helio G95/曦力G95核心板定制

MT6785安卓核心板是基于MT6785(Helio G95)处理器&#xff0c;具备八核处理器结构&#xff0c;包括2颗主频为2.05GHz的Cortex A76处理器和6颗主频为2.0GHz的Cortex A55处理器&#xff0c;以及六颗Cortex-A55处理器。而在GPU方面&#xff0c;采用了Arm Mali-G76 MC4&#xff0c;频…

Modbus转Profinet网关揭秘!升级工业自动化!

Modbus转Profinet网关&#xff08;XD-MDPN100/200&#xff09;通过Modbus协议和Profinet协议之间的转换&#xff0c;实现了不同设备之间的通信。Modbus是一种常用的串行通信协议&#xff0c;而Profinet是一种基于以太网的工业通信协议。随着工业自动化的不断发展&#xff0c;Mo…

3.6 QUERYING DEVICE PROPERTIES

我们关于将执行资源分配给区块的讨论提出了一个重要问题。我们如何确定可用资源的数量&#xff1f;当CUDA应用程序在系统上执行时&#xff0c;它如何确定设备中的SM数量以及可以分配给每个SM的块和线程数量&#xff1f;可能与执行CUDA应用程序相关的其他资源尚未讨论。一般来说…

12.8-1.8

2023.12.8 redis容器 docker run -p 6379:6379 --name redis -v /mydata/redis/data:/data -v /mydata/redis/conf/redis.conf:/etc/redis/redis.conf -d redis redis-server /etc/redis/redis.conf redis.conf不存在&#xff0c;需先在宿主机创建该目录下文件&#xff0c…

《亚太教育》是什么级别的期刊?是正规期刊吗?能评职称吗?

《亚太教育》主要发表教育理论研究、教育教学实践、学校管理、学科教育、科研管理等学术论文以及其他与教育教学相关的学术论文和研究成果,现征集教育管理以及各学科优秀论文。欢迎.各位教师、教育工作者及高校学生踊跃投稿。 收录情况&#xff1a;知网万方维普收录 投稿方式&a…

主播职业发展

主播作为当今互联网时代的新兴职业&#xff0c;拥有着广阔的发展前景和无限的可能性。为了在竞争激烈的市场中脱颖而出&#xff0c;主播需要不断提升自己的专业技能&#xff0c;拓展知识领域&#xff0c;增强互动能力&#xff0c;积累粉丝基础&#xff0c;寻求合作机会&#xf…

实现导航栏吸顶操作

一、使用VueUse插件 // 安装 npm i vueuse/core二、点击搜索useScroll 2.1搜索结果如图 三、使用 // 这是示例代码 import { useScroll } from vueuse/core const el ref<HTMLElement | null>(null) const { x, y, isScrolling, arrivedState, directions } useSc…

TS2307: Cannot find module ‘./App.vue‘ or its corresponding type declarations.

目录 1. 问题描述2. 解决方案一&#xff1a;VSCode Volar&#xff08;官方推荐&#xff09;3. 解决方案二&#xff1a;WebStorm 2023.2 &#xff08;官方推荐&#xff09;4. 解决方案三&#xff1a;禁用严格类型检查选项&#xff08;不推荐&#xff09;5. 解决方案四&#xff…

redhat+ oracle 11.2.0.4 RAC 搭建 dataguard

知识改变命运&#xff0c;技术就是要分享&#xff0c;有问题随时联系&#xff0c;免费答疑&#xff0c;欢迎联系&#xff01; redhat oracle 11.2.0.4 RAC 搭建 dataguard 1.安装环境 主机名 OS DB SID db_name db_unique_name rac1 Redhat7 11.2.0.4 orcl1 orcl o…

用React给XXL-JOB开发一个新皮肤(一):环境搭建和项目初始化

目录 一. 简述二. Fork 项目三. 搭建开发环境四. 初始化皮肤项目五. 添加相关依赖六. 预览 一. 简述 大名鼎鼎的 xxl-job 任务调度中心我们应该都使用过&#xff0c;项目地址&#xff1a;xxl-job。它是一个分布式任务调度平台&#xff0c;其核心设计目标是开发迅速、学习简单…