Linux线程互斥锁

目录

🚩看现象,说原因

🚩解决方案

🚩互斥锁

 🚀关于互斥锁的理解

🚀关于原子性的理解

🚀如何理解加锁和解锁是原子的

🚩对互斥锁的简单封装


引言

大家有任何疑问,可以在评论区留言或者私信我,我一定尽力解答。

今天我们学习Linux线程互斥的话题。Linux同步和互斥是Linux线程学习的延伸。但这部分挺有难度的,请大家做好准备。那我们就正式开始了。

🚩看现象,说原因

我们先上一段代码:

#include<iostream>
#include<pthread.h>
#include<unistd.h>
#include<vector>
#include<cassert>
using namespace std;
int NUM=5;
int ticket=1000;
class pthread
{
public:char buffer[1024];pthread_t id;
};
void *get_ticket(void *args)
{pthread *pth=static_cast<pthread*>(args);while(1){usleep(1234);if(ticket<0){return nullptr;}cout<<pth->buffer<<" is ruuing ticket: "<<ticket<<endl;ticket--;}
}int main()
{vector<pthread*> pthpool;for(int i=0;i<NUM;i++){pthread* new_pth=new pthread();snprintf(new_pth->buffer,sizeof (new_pth->buffer),"thread-%d",i+1);int n=pthread_create(&(new_pth->id),nullptr,get_ticket,new_pth);assert(n==0);(void)n;pthpool.push_back(new_pth);}for(int i=0;i<pthpool.size();i++){int m= pthread_join(pthpool[i]->id,nullptr);assert(m==0);(void)m;}return 0;}

这段代码模拟的是抢票模型,一共有一千张票,我们让几个线程同时去抢票。看看有什么不符合实际的情况发生。

还真有不符合实际的情况发生:竟然抢到了负票。卧槽,这是什么情况,我们赶紧分析一下。

首先,在代码中我们定义了一个全局变量:ticket 。这个变量被所有线程所共享。

对于这种情形,我们直接拉向极端情况:假设此时的票数只有一张了。一个线程进入if内部,但是对票数还没有进行操作,这时,时间片到了,这个线程被切了下去。紧接着,一个线程就通过if判断,顺利抢到了最后一张票,对票数进行了操作。此时已经无票可抢了。这时,那个被切下来的线程又带着它的数据开始了抢票。但是在这个线程看来,票数依旧还有最后一张,所以,它又对票数进行了减减操作,得到了负票。

这种情况显然是不合理的,假如一个电影院有100个座位,结果卖出去102张票,这怎么可以呢?

我们定义的全局变量,在没有保护的情况下,往往晒不安全的。像上面多个线程在交替执行时造成的数据安全问题,我们称之为出现了数据不一致问题

这就是个坑啊,必须解决。

🚩解决方案

在提出解决方案之前,我们先回顾几个概念。

  • 多个执行流进行安全访问的共享资源,叫做临界资源
  • 我们把多个执行流中,访问临界资源的代码叫做临界区,临界区往往是线程代码很小的一部分。
  • 想让多个线程串行访问共享资源的方式叫做互斥
  • 对一个资源进行访问的时候,要么不做,要么做完,这种特性叫做原子性。一个对资源进行的操作,如果只有一挑汇编语句完成,那么就是原子的,反之就不是原则的。这是当前我们对原子性的理解,后面还会发生改变。

 我们提出的解决方案就是加锁。相信大家第一次听到锁。对于什么是锁,如何加锁,锁的原理是什么我们都不清楚,别着急,我们在接下来的内容里会进行详细的详解。

我们先使用一下锁,见见猪跑!!

#include<iostream>
#include<pthread.h>
#include<unistd.h>
#include<vector>
#include<cassert>
using namespace std;
int NUM=5;
int ticket=1000;
pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER;
class pthread
{
public:char buffer[1024];pthread_t id;
};
void *get_ticket(void *args)
{pthread *pth=static_cast<pthread*>(args);while(1){  pthread_mutex_lock(&mutex);usleep(1234);if(ticket<0){  pthread_mutex_unlock(&mutex);return nullptr;}cout<<pth->buffer<<" is ruuing ticket: "<<ticket<<endl;ticket--;pthread_mutex_unlock(&mutex);}
}int main()
{vector<pthread*> pthpool;for(int i=0;i<NUM;i++){pthread* new_pth=new pthread();snprintf(new_pth->buffer,sizeof (new_pth->buffer),"user-%d",i+1);int n=pthread_create(&(new_pth->id),nullptr,get_ticket,new_pth);assert(n==0);(void)n;pthpool.push_back(new_pth);}for(int i=0;i<pthpool.size();i++){int m= pthread_join(pthpool[i]->id,nullptr);assert(m==0);(void)m;}return 0;}

 

结果显示抢票的过程非常顺利,接下来,我们把重心指向锁。

🚩互斥锁

 首先,我们先认识一些锁的常见接口

// 所有锁的相关操作函数都在这个头文件下
//这些函数如果又返回值,操作成功的话,返回0,失败的话。返回错误码。错误原因被设置
#include <pthread.h>
// 锁的类型,用来创建锁
pthread_mutex_t
// 对锁进行初始化,第二个参数一般设位null
int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr);
// 如果这个锁没有用了,可以调用该函数对锁进行销毁
int pthread_mutex_destroy(pthread_mutex_t *mutex);
// 如果创建的锁是全局变量,可以这样初始化。
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
// 对特定代码部分进行上锁,这部分代码只能有一次只能有一个执行流进入,被保护的资源叫做临界资源。
int pthread_mutex_lock(pthread_mutex_t *mutex);
// 尝试上锁,不一定成功。
int pthread_mutex_trylock(pthread_mutex_t *mutex);
// 取消锁。
int pthread_mutex_unlock(pthread_mutex_t *mutex);

刚刚,我们已经使用一种方式实现了加锁,接下来,我们用另一种方式:

#include <iostream>
#include <pthread.h>
#include <unistd.h>
#include <vector>
#include <cassert>
using namespace std;
int NUM = 5;
int ticket = 1000;
class Thread_Data
{
public:Thread_Data(string name,pthread_mutex_t* mutex):_name(name),_mutex(mutex){}~Thread_Data(){}
public:string _name;pthread_mutex_t*  _mutex;
};
void *get_ticket(void *args)
{Thread_Data *pth = static_cast<Thread_Data*>(args);while (1){pthread_mutex_lock(pth->_mutex); if (ticket > 0){  usleep(1234); cout << pth->_name << " is ruuing ticket: " << ticket << endl;  ticket--;pthread_mutex_unlock(pth->_mutex); } else{pthread_mutex_unlock(pth->_mutex);break;}}
}int main()
{pthread_mutex_t mutex;pthread_mutex_init(&mutex,nullptr);vector<pthread_t> tids(NUM); for (int i = 0; i < NUM; i++){char buffer[1024];Thread_Data *td=new Thread_Data(buffer,&mutex);snprintf(buffer, sizeof(buffer), "user-%d", i + 1);int n =pthread_create(&tids[i], nullptr, get_ticket, td);assert(n == 0);(void)n;}for (int i = 0; i < tids.size(); i++){int m = pthread_join(tids[i], nullptr);assert(m == 0);(void)m;}return 0;
}

 

运行一下,发现一直是4号线程在跑,其他线程呢?我也没让其他线程退出呀!而且抢票的时间变长了。

  • 加锁和解锁是多个线程串行进行的,所以程序允许起来会变得很慢。
  • 锁只规定互斥访问,没有规定谁优先访问。
  • 锁就是让多个线程公平竞争的结果,强者胜出嘛。

 🚀关于互斥锁的理解

  • 所有的执行流都可以访问这一把锁,所以锁是一个共享资源。
  • 加锁和解锁的过程必须是原子的,不会存在中间状态。要么成功,要么失败。加锁的过程必须是安全的。
  • 谁持有锁,谁进入临界区。

 如果一个执行流申请锁成功,继续向后运行;如果申请失败的话,这个执行流怎么办?

这种情况试一试不就知道了。我们依旧使用上面的一份代码,稍稍做一下修改:

 

所以,当一个执行流申请锁失败时,这个执行流会阻塞在这里。


🚀关于原子性的理解

如图,三个执行流

 

问:如果线程1申请锁成功,进入临界资源,正在访问临界资源区的时候,其他线程在做什么?

 答:都在阻塞等待,直到持有锁的线程释放锁。

问; 如果线程1申请锁成功,进入临界资源,正在访问临界资源区的时候,可不可以被切换?

答:绝对是可以的,CPU管你有没有锁呢,时间片到了你必须下来。当持有锁的线程被切下来的时候,

是抱着锁走的,即使自己被切走了,其他线程依旧无法申请锁成功,也就无法继续向后执行。

这就叫作:江湖上没有我,但依旧有我的传说。

所以对于其他线程而言,有意义的锁的状态,无非两种:①申请锁前,②释放锁后

 所以,站在其他线程的角度来看待当前持有锁的过程,就是原子的。

 所以,未来我们在使用锁的时候,要遵守什么样的原则呢?

  • 一定要保证代码的粒度(锁要保护的代码的多少i)要非常小。
  • 加锁是程序员的行为,必须做到要加的话所有的线程必须要加锁。

🚀如何理解加锁和解锁是原子的

 在分析如何实现加锁和解锁之前,我们先形成几个共识:

  • CPU内执行流只有一套,且被所有执行流所共享。
  • CPU内寄存器的内容属线程所有,是每个执行流的上下文。时间片到达,数据带走。
  • 在进行加锁和解锁的时候,这个线程随时会因时间片已到而被换下来。

为了实现互斥锁操作,大多数体系结构都提供了swap或exchange指令,该指令的作用是把寄存器和内存单元的数据相交换,由于只有一条指令,保证了原子性 。

如图:

我们假设有线程A,B两个线程,A想要获得锁 

锁内存储的数据就是int类型的1。 A线程中有数字0。

①:movb $0,%al:将线程A中的1move到寄存器中。此时,是有可能发生时间片到达的,但是寄存器内的数据属于线程A,线程A是要带走的。

②:xchgb %al,mutex:将锁中的数据和寄存器内的数据进行交换。此时寄存器内的数据变成1,锁中的数据变为0。这是关键的一步,也有可能会发生切换。假设不巧的很,A线程被切下去了,B线程被切上来了。B线程从第一步开始,走到现在,寄存器内的数据应该是0。然后进入判断体eles进行挂起等待。

③如果在第二步中线程A被切下来,等待一段时间,时间片再次轮到线程A时,A将自己的数据加载到寄存器内进入判断,然后获得锁。

交换的过程由一条汇编构成

交换的本质:共享的数据,交换到线程的上下文中。 

那么。如何完成解锁的操作呢。解锁的操作特别简单,只需一步。

将寄存器内的1归还给锁。然后return返回就可以了。

🚩对互斥锁的简单封装

相信大家对互斥锁都有了充分的了解。接下来,我们就实现一下对互斥锁的简单封装。

#include <iostream>
#include <pthread.h>
#include <unistd.h>
#include <vector>
#include <cassert>class Mutex
{
public:Mutex(pthread_mutex_t *mutex) : _mutex(mutex){}void unlock(){if (_mutex){pthread_mutex_unlock(_mutex);}}void lock(){if(_mutex){pthread_mutex_lock(_mutex);}}~Mutex(){}public:pthread_mutex_t *_mutex;
};
class Lockguard
{
public:Lockguard(Mutex mutex) : _mutex(mutex){_mutex.lock();}~Lockguard(){_mutex.unlock();}public:Mutex _mutex;
};

这种利用变量出了函数作用域自动销毁的性质,我们称之为RAII特性。

到这里,我们本篇的内容也就结束了,我们期待下一期博客相遇。

 

 

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

如若内容造成侵权/违法违规/事实不符,请联系长河编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Unity踩坑记录

1. 如果同时在父物体和子物体上挂载BoxCollider&#xff0c;那么当使用&#xff1a; private void OnTriggerEnter2D(Collider2D collision){if (collision.CompareTag("CardGroup")){_intersectCardGroups.Add(collision.GetComponent<CardGroup>());}} 来判…

掌握SEO:如何优化用ChatGPT生成的文章以提升搜索排名

在数字化时代&#xff0c;搜索引擎优化&#xff08;SEO&#xff09;已经成为网站流量的重要来源。随着人工智能技术的进步&#xff0c;越来越多的人开始使用ChatGPT等AI工具来生成文章。然而&#xff0c;虽然这些工具可以快速生成内容&#xff0c;但要确保这些内容在搜索引擎中…

World of Warcraft [CLASSIC] Level 70 Dire Maul (DM)

[月牙钥匙] [大型爆盐炸弹] World of Warcraft [CLASSIC] Level 70 厄运之槌&#xff0c;完美贡品&#xff0c;Dire Maul &#xff08;DM&#xff09; Foror‘s Compendium of Dragon Slaying 佛洛尔的屠龙技术纲要 因为不是兽王宝宝&#xff0c;而且开始位置放的不对&am…

WPF文本绑定显示格式StringFormat设置-特殊格式时间日期和多数据绑定

WPF文本绑定显示格式StringFormat设置 特殊格式设置日期/时间使用系统默认样式自定义格式&#xff1a; 绑定多个属性&#xff08;多重绑定&#xff09;多重绑定中的特殊字符示例&#xff1a; 特殊格式设置 在Textblock等文本控件中&#xff0c;我们经常要显示一些日期和时间&a…

【C++:list】

list概念 list是一个带头的双向循环链表&#xff0c;双向循环链表的特色&#xff1a;每一个节点拥有两 个指针进行维护&#xff0c;俩指针分别为prev和next,prev指该节点的前一个节点&#xff0c;next为该节点的后一个节点 list的底层实现中为什么对迭代器单独写一个结构体进行…

浏览器扩展V3开发系列之 chrome.contextMenus 右键菜单的用法和案例

【作者主页】&#xff1a;小鱼神1024 【擅长领域】&#xff1a;JS逆向、小程序逆向、AST还原、验证码突防、Python开发、浏览器插件开发、React前端开发、NestJS后端开发等等 chrome.contextMenus 允许开发者向浏览器的右键菜单添加自定义项。 在使用 chrome.contextMenus 之前…

使用命令行创建uniapp+TS项目,使用vscode编辑器

一:如果没有pnpm,先安装pnpm 二:使用npx工具和degit工具从 GitHub 上的 dcloudio/uni-preset-vue 仓库克隆一个名为 vite-ts 的分支,到项目中. 执行完上面命令后,去manifest.json添加appid(自己微信小程序的Id),也可不执行直接下一步,执行pnpm install ,再执行pnpm:dev:mp-weix…

【技巧】如何检查多个GPU之间是否支持P2P通信

转载请注明出处&#xff1a;小锋学长生活大爆炸[xfxuezhagn.cn] 如果本文帮助到了你&#xff0c;欢迎[点赞、收藏、关注]哦~ 需要用到cuda_samples&#xff1a;GitHub - NVIDIA/cuda-samples 该工具的详细解释可以看这个&#xff1a; 【知识】详细介绍 CUDA Samples 示例工程…

利用Python控制终端打印字体的颜色和格式

利用Python控制终端打印字体的颜色和格式—操作详解&#xff08;ANSI转义序列&#xff09; 一、问题描述二、ANSI转义序列三、具体代码和显示效果&#xff08;看懂这段代码&#xff0c;以后可随心控制字体的打印格式&#xff09; 欢迎学习交流&#xff01; 邮箱&#xff1a; z……

Redis-使用 jedis 操作数据

文章目录 1、Jedis简介2、环境准备3、创建maven普通项目,导入如下依赖4、测试JAVA程序和Redis之间的通信 1、Jedis简介 "Jedis" 通常是作为 "Java Redis" 的缩写或简称来理解的。Java Embedded Data Structures Interface 表示 Java嵌入式数据结构接口 2、…

9.二维数组的遍历和存储

二维数组的遍历和存储 二维数组的遍历 二维数组a[3][4],可分解为三个一维数组,其数组名分别为: 这三个一维数组都有4个元素,例如:一维数组a[0]的 元素为a[0][0],a[0][1],a[0][2],a[0][3]。所以遍历二维数组无非就是先取出二维数组中得一维数组, 然后再从一维数组中取出每个元…

TextRank 算法

第1关&#xff1a;Jieba 在关键词提取中的应用 任务描述 本关任务&#xff1a;根据本关所学有关使用 Jieba 库进行关键词提取的知识&#xff0c;编写使用 Jieba 模块进行关键词提取的程序&#xff0c;并通过所有测试用例。 相关知识 为了完成本关任务&#xff0c;你需要掌握…

oracle12c到19c adg搭建(六)切换后12c备库服务器安装19c软件在19c主库升级数据字典后尝试同步

一、安装19c软件 参考文章oracle12c到19c adg搭建&#xff08;三&#xff09;oracle19c数据库软件安装 二、原主库尝试通过19c软件启动数据库 2.1复制12c的相关参数文件和密码文件到19c目录 注意:密码文件需要从已切换主库19c传过来 [oracleo12u19p ~]$ cd /u01/app/oracle…

ubuntu多版本cuda如何指定cuda版本

本文作者&#xff1a; slience_me ubuntu多版本cuda如何指定cuda版本 文章目录 ubuntu多版本cuda如何指定cuda版本1. 关于cuda设置1.1 查看当前安装的 CUDA 版本1.2 下载并安装所需的 CUDA 版本1.3 设置环境变量1.4 验证切换1.5 安装对应的 NVIDIA 驱动程序 2. 设置环境变量2.1…

提取url中的参数

let url https://alibaba.com?a1&b2&c3#hash function queryUrlParams(URL){let url URL.split(?)[1];const urlSearchParams new URLSearchParams(url);console.log(url1, urlSearchParams);console.log(entries,urlSearchParams.entries())const params Object…

.hmallox勒索病毒解密方法|勒索病毒解决|勒索病毒恢复|数据库修复

导言&#xff1a; 在当今数字化时代&#xff0c;勒索病毒已经成为网络安全的一大威胁&#xff0c;其中包括了最近出现的.hmallox勒索病毒。这类恶意软件不仅能够对计算机系统进行加密&#xff0c;还会要求用户支付赎金以换取解密密钥&#xff0c;给个人用户和企业带来了严重的…

HTTP详解

目录 1.定义 2.工作流程 3.Fiddler 3.1 使用 3.2 工作原理 4.URL 5.请求和响应 5.1 请求 5.2 响应 6.GET和POST 6.1 经典面试题&#xff1a;GET和POST的区别 6.2 GET 6.3 POST 7.请求报头&#xff08;Header&#xff09; 7.1 HOST 7.2 Content-Length 7.3 …

说一说ABAP CDS View的发展历史与特性

1. 背景 随着SAP Fiori应用程序的兴起&#xff0c;SAP领域的小伙伴接触和使用ABAP CDS View的机会也是越来越多。今天&#xff0c;让我们花些时间&#xff0c;一起在了解下这项技术的设计初衷和发展历史。 2. 设计初衷 说起ABAP CDS View&#xff0c;就不得不提及SAP HANA。…

指针并不是用来存储数据的,而是用来存储数据在内存中地址(内存操作/函数指针/指针函数)

推荐&#xff1a;1、4、5号书籍 1. 基本概念 首先&#xff0c;让小明了解指针的基本概念&#xff1a; 指针的定义&#xff1a;指针是一个变量&#xff0c;它存储的是另一个变量的地址。指针的声明&#xff1a;例如&#xff0c;int *p表示一个指向整数的指针变量p。 2. 形象…

编程入门指南

一、了解编程与编程语言 编程&#xff1a;编程是使计算机按照人类编写的指令进行工作的过程。这些指令被编写成计算机可以理解的代码&#xff0c;称为程序。编程语言&#xff1a;编程语言是人与计算机交流的工具。常见的编程语言有Python、Java、C、JavaScript等。 二、选择编…