Linux下线程的互斥与同步详解

🤖个人主页：晚风相伴-CSDN博客

💖如果觉得内容对你有帮助的话，还请给博主一键三连（点赞💜、收藏🧡、关注💚）吧

🙏如果内容有误或者有写的不好的地方的话，还望指出，谢谢！！！

让我们共同进步

​

下一篇《生产者消费者模型》敬请期待

目录

🔥线程间互斥的相关概念

💪互斥量的接口

初始化互斥量

销毁互斥量

互斥量的加锁与解锁

🔥探究互斥量实现原理

可重入函数和线程安全 

两者的概念区分 

常见的线程不安全和安全情况

可重入与线程安全的联系与区别

☀死锁 

产生死锁的四个必要条件

避免死锁

🔥线程同步 

条件变量 

同步的概念与竞态条件

🔥条件变量接口

初始化 

销毁条件 

条件等待

唤醒等待

🔥解释pthread_cond_wait中的互斥量

🔥线程间互斥的相关概念

  • 临界资源：多线程执行流共享的资源就叫做临界资源
  • 临界区：每个线程内部，访问临界资源的代码，就叫做临界区
  • 互斥：任何时刻，互斥保证有且只有一个执行流进入临界区，访问临界资源，通常对临界资源其保护作用
  • 原子性：不会被任何调度机制打断的操作，该操作只有两种状态，要么完成，要么未完成。

先来看看下面简单实现的抢票的代码

int tickets = 1000;void* getTickets(void* args){(void)args;while(true){if(tickets > 0){usleep(1000);printf("%p: %d\n", pthread_self(), tickets);tickets--;}else{break;}}return nullptr;}int main(){pthread_t t1, t2, t3;pthread_create(&t1, nullptr, getTickets, nullptr);pthread_create(&t1, nullptr, getTickets, nullptr);pthread_create(&t1, nullptr, getTickets, nullptr);pthread_join(t1, nullptr);pthread_join(t2, nullptr);pthread_join(t3, nullptr);return 0;}

结果演示

​

💪为什么结果会出现-1呢？

原因：首先要知道一个线程什么时候被调度，调度多长时间，完全是有计算机确定的，程序员决定不了。tickets在进行减减操作时，是分三步的

①读取数据到CPU内的寄存器中

②CPU内部进行计算--

③将结果写回内存中

为了方便叙述，这里给线程编个号

一号线程来了，由于时间片很短执行到第②步就被切走了，二号线程来了，它没有被打断，所以它执行完了这三步，并且这个线程的优先级比较高，一直执行tickets--操作，直到tickets减到1停止，在执行到第①步的时候被切走了，而一号线程回来了，继续从它被打断的地方继续向后执行，也就是从第②步开始继续向后执行，在写回内存后，tickets已经减到了1，但是这个线程又把tickets修改为了999，并且这时它的时间片很长，所以这次又一直将tickets减到了1，由于判断条件tickets不为0，所以tickets继续减减操作，此时tickets减为了0，此时二号线程来了，将0读入到寄存器中进行减减操作，所以结果出现了-1，这就导致了问题的出现。

​

 要解决上面的问题，就需要做到以下三点：

  1. 代码必须要有互斥行为：当代码进入临界区执行时，不允许其它线程进入临界区。
  2. 如果多个线程同时要求执行临界区的代码，并且临界区没有线程在执行，那么只能允许一个线程进入该临界区。
  3. 如果线程不在临界区中执行，那么该线程不能阻止其它线程进入临界区。

要做到以上三点，就需要一把互斥锁，将临界区资源锁住，没有拿到钥匙的线程就不能访问临界区资源，这就能做到保护了临界区资源。Linux上提供的这把互斥锁叫互斥量。

​

💪互斥量的接口

初始化互斥量

有两种方式初始化互斥量

方法一：全局初始化分配

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER

方法二：局部初始化分配

int pthread_mutex_init(pthread_mutex_t *restrict mutex, const pthread_mutexattr_t *restrict attr);

参数：

  • mutex：要初始化的互斥量
  • attr：nullptr

返回值：成功返回0，失败返回错误码

销毁互斥量

 int pthread_mutex_destroy(pthread_mutex_t *mutex);

参数：

  • mutex：要销毁的互斥量

返回值：成功返回0，失败返回错误码

 销毁互斥量时需要注意

  • 使用全局初始化的互斥量不需要销毁
  • 不要销毁一个已经加锁的互斥量
  • 已经销毁的互斥量要确保后面的代码中不再有加锁的操作

互斥量的加锁与解锁

int pthread_mutex_lock(pthread_mutex_t *mutex);
int pthread_mutex_unlock(pthread_mutex_t *mutex);
返回值:成功返回0，失败返回错误码

 调用pthread_mutex_lock加锁时，可能会遇到以下情况：

  • 互斥量还没被加锁，处于未锁定状态，那么调用该函数会将互斥量加锁锁定。
  • 在调用该函数之前，其它线程已经申请了锁，锁定了该互斥量，或者存在其它线程同时竞争式的申请互斥量，但没有竞争到互斥量，那么调用pthread_mutex_lock就会被阻塞，等待会吃两解锁。

所以将上面的抢票代码修改如下：

int tickets = 1000; // 临界资源class ThreadData
{
public:ThreadData(string &name, pthread_mutex_t *pmtx) : _tname(name), _pmtx(pmtx){}public:string _tname;pthread_mutex_t *_pmtx;
};void *getTickets(void *args)
{ThreadData* td = (ThreadData*)args;while (true){int n = pthread_mutex_lock(td->_pmtx); // 加锁保护临界区资源assert(n == 0);if (tickets > 0){usleep(1000);printf("%s : %d\n", td->_tname.c_str(), tickets);cout << td->_tname << " : " << tickets << endl;tickets--;n = pthread_mutex_unlock(td->_pmtx);assert(n == 0);}else{n = pthread_mutex_unlock(td->_pmtx);assert(n == 0);break;}// 处理后续的动作cout << "恭喜，抢票成功" << endl;usleep(1000);}return nullptr;
}#define THREAD_NUM 5int main()
{pthread_mutex_t mtx;pthread_mutex_init(&mtx, nullptr); // 局部定义的锁进行初始化的形式pthread_t tid[THREAD_NUM];for (int i = 0; i < THREAD_NUM; i++){string name = "thread ";name += to_string(i + 1);ThreadData *td = new ThreadData(name, &mtx);pthread_create(tid + i, nullptr, getTickets, (void *)td);}for (int i = 0; i < THREAD_NUM; i++){pthread_join(tid[i], nullptr);}pthread_mutex_destroy(&mtx); // 最后将锁释放掉return 0;
}

 结果演示：

​

🔥探究互斥量实现原理

加锁的目的是保证操作的原子性。 从汇编的角度来看，如果只有一条汇编语句，我们就认为该汇编语句的执行是原子的， 在汇编中给我们提供了swap或者exchange指令，该指令的作用是将内存中的数据与CPU内寄存器中的数据（CPU内寄存器中的数据也叫做执行流的上下文，寄存器的空间是被所有执行流锁共享的，但是里面的数据是被某一个执行流私有的）进行交换，由于只有一条指令，所以可以保证其原子性。

​

​

解锁时会把互斥量变为1。

可重入函数和线程安全 

两者的概念区分 

线程安全：多个线程并发执行同一段代码时，不会出现不同的结果。
重入：同一个函数被不同的执行流调用，当前一个执行流还没有执行完，就有其它的执行流再次进入该函数，我们称这种情况是重入。一个函数在重入的情况下，运行结果不会出现任何不同或者任何问题，则该函数被称为可重入函数，否则称为不可重入函数。

常见的线程不安全和安全情况

不安全情况：

  • 不保护共享变量的函数
  • 函数状态随着被调用，状态发生变化的函数
  • 返回指向静态变量指针的函数
  • 调用线程不安全函数的函数

 安全情况：

  •  每个线程对全局变量或者静态变量只有读取权限，而没有写入权限，一般来说这些线程是安全的。
  • 类或者接口对于线程来说都是原子操作的
  • 多个线程之间的切换不会导致该接口的执行结果存在二义性

可重入与线程安全的联系与区别

联系：

  • 函数是可重入的，那就是线程安全的。
  • 函数是不可重入的，那就不能由多个线程使用，有可能引发线程安全问题。
  • 如果一个函数中有全局变量，那么这个函数既不是线程安全也不是可重入的。

区别：

  • 可重入函数是线程安全函数的一种
  • 线程安全不一定是可重入的，而可重入函数则一定是线程安全的
  • 如果对临界资源的访问加上锁，则这个函数是线程安全的，但如果这个可重入函数的锁还未释放则会产生死锁，因此是不可重入的。

☀死锁 

死锁是指子在一组进程中的各个进程均占有不会释放的资源，但因互相申请被其它进程所占用不会释放的资源而处于的一种永久等待状态。

产生死锁的四个必要条件

  • 互斥条件：一个资源每次只能被一个执行流使用
  • 请求与保持条件：一个执行流因请求支援而阻塞时，对已获得的资源保持不放
  • 不剥夺条件：一个执行流已获得的资源，在未使用完之前，不能被强行剥夺
  • 循环等待条件： 若干执行流之间形成一种头尾相接的循环等待资源的关系

避免死锁

  • 破坏死锁的四个必要条件
  • 加锁顺序一致
  • 避免锁未释放的场景
  • 资源一次性分配
  • 对死锁检测
  • 银行家算法

🔥线程同步 

条件变量 

当我们申请临界资源前，要先检测临界资源是否存在，做检测的本质也是在访问临界资源，所以对临界资源的检测一定是要在加锁和解锁之间的。例如一个线程访问队列时，发现队列为空，那么它只能等待，直到其它线程将一个节点添加到队列中，在检测队列是否为空时，如果该线程一直轮询检测，那么势必要频繁的申请锁和释放锁，这样太浪费资源了，那么这种情况就需要用到条件变量了。

因此条件变量可以让线程不在频繁的自己检测了，当第一次检测到条件不满足时就挂起等待，当条件满足时，再通知该线程，让它来申请资源和访问。

同步的概念与竞态条件

同步：在保证数据安全的前提下，让线程能够按照某种特定的顺序访问临界资源，从而有效的解决了访问临界资源的合理性问题。

竞态条件：因为时序问题，而导致程序异常，我们称之为竞态条件。

🔥条件变量接口

初始化 

和互斥量那里一样分为全局初始化和局部初始化

局部初始化 

int pthread_cond_init(pthread_cond_t *restrict cond，const pthread_condattr_t *restrict attr)；

参数：

  • cond：要初始化的条件变量
  • attr：设置为nullptr即可

返回值：成功返回0，失败返回错误码

全局初始化

pthread_cond_t cond = PTHREAD_COND_INITIALIZER; 

销毁条件 

int pthread_cond_destroy(pthread_cond_t *cond) ;

条件等待

int pthread_cond_wait(pthread_cond_t *restrict cond,pthread_mutex_t *restrict mutex);
参数：

  • cond：要在这个条件变量上等待
  • mutex：互斥量

唤醒等待

int pthread_cond_broadcast(pthread_cond_t *cond);//唤醒一批线程
int pthread_cond_signal(pthread_cond_t *cond);//唤醒某个线程

示例代码

#include <iostream>
#include <pthread.h>
#include <string>
#include <unistd.h>
using namespace std;#define NUM 4
typedef void (*func_t)(const string name, pthread_mutex_t *pmtx, pthread_cond_t *pcond);
volatile bool quit = false;class ThreadData
{
public:ThreadData(string &name, func_t func, pthread_mutex_t *pmtx, pthread_cond_t *pcond): _name(name), _func(func), _pmtx(pmtx), _pcond(pcond){}public:string _name;func_t _func;pthread_mutex_t *_pmtx;pthread_cond_t *_pcond;
};void func1(const string name, pthread_mutex_t *pmtx, pthread_cond_t *pcond)
{while(!quit){pthread_mutex_lock(pmtx);pthread_cond_wait(pcond, pmtx);//线程等待cout << name << " running... -- 1" << endl;// sleep(1);pthread_mutex_unlock(pmtx);}
}void func2(const string name, pthread_mutex_t *pmtx, pthread_cond_t *pcond)
{while(!quit){pthread_mutex_lock(pmtx);pthread_cond_wait(pcond, pmtx);//线程等待cout << name << " running... -- 2" << endl;// sleep(1);pthread_mutex_unlock(pmtx);}
}void func3(const string name, pthread_mutex_t *pmtx, pthread_cond_t *pcond)
{while(!quit){pthread_mutex_lock(pmtx);pthread_cond_wait(pcond, pmtx);//线程等待cout << name << " running... -- 3" << endl;// sleep(1);pthread_mutex_unlock(pmtx);}
}void func4(const string name, pthread_mutex_t *pmtx, pthread_cond_t *pcond)
{while(!quit){pthread_mutex_lock(pmtx);pthread_cond_wait(pcond, pmtx);//线程等待cout << name << " running... -- 4" << endl;// sleep(1);pthread_mutex_unlock(pmtx);}
}void* Entry(void* args)
{ThreadData* tmp = (ThreadData*)args;tmp->_func(tmp->_name, tmp->_pmtx, tmp->_pcond);delete tmp;return nullptr;
}int main()
{pthread_mutex_t mtx;pthread_cond_t cond;pthread_mutex_init(&mtx, nullptr);pthread_cond_init(&cond, nullptr);pthread_t tid[NUM];func_t funcs[NUM] = {func1, func2, func3, func4};for (int i = 0; i < NUM; i++){string name = "thread ";name += to_string(i + 1);ThreadData* td = new ThreadData(name, funcs[i], &mtx, &cond);pthread_create(tid + i, nullptr, Entry, (void*)td);}int cnt = 10;while(cnt){cout << "resume thread run code..." << cnt-- << endl;pthread_cond_signal(&cond);// pthread_cond_broadcast(&cond);sleep(1);}cout << "ctrl done" << endl;quit = true;pthread_cond_broadcast(&cond);for(int i = 0; i < NUM; i++){pthread_join(tid[i], nullptr);cout << "pthread: " << tid[i] << " quit" << endl; }pthread_mutex_destroy(&mtx);pthread_cond_destroy(&cond);return 0;
}

结果演示

 ​

按照一定的顺序执行。

🔥解释pthread_cond_wait中的互斥量

条件等待是线程间同步的一种手段，如果只有一个线程，条件不满足，一直等下去也都不会满足，所以必须还要有一个线程通过某些操作来改变共享变量，使得不满足的条件变得满足，并且友好的通知在条件变量上等待的线程。但是条件不会无缘无故的满足，这必然会牵扯到共享数据的改变。共享数据属于临界资源，因此一定要用互斥锁来保护，没有互斥锁的保护就无法安全的获取和修改共享数据了。

​

按照上面的说法，我们转换成代码，必须先上锁，检测到条件不满足时，pthread_cond_wait会解锁，然后在条件变量上等待，直到条件满足时，pthread_cond_wait又会重新加锁。

进入pthread_cond_wait函数后，会去检测条件是否满足，如果不满足就把互斥量变为1（解锁），直到条件满足后（pthread_cond_wait返回）将互斥量恢复成原样。

条件变量的规范使用如下：

//等待条件代码
pthread_mutex_lock(&mtx);
while(条件检测)pthread_cond_wait(&cond, &mtx);
//修改条件
pthread_mutex_unlock(&mtx);//条件满足，唤醒线程代码
pthread_mutex_lock(&mtx);
//设置条件满足
pthread_cond_signal(&cond);
pthread_mutex_unlock(&mtx);

 ​

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

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

相关文章

android:text 总为大写字母的原因

android:text 总为大写字母的原因

当设置某个 Button 的 text 为英文时&#xff0c;界面上显示的是该英文的大写形式&#xff08;uppercase&#xff09;。例如&#xff1a; <Buttonandroid:id"id/btn"android:layout_width"wrap_content"android:layout_height"wrap_content"…
阅读更多...
centos7 安装 mysql5.7 LTS

centos7 安装 mysql5.7 LTS

centos7 安装 mysql5.7 LTS 参考&#xff1a; https://blog.csdn.net/EB_NUM/article/details/105425622 可以在运行安装程序之前导入密钥&#xff1a; sudo rpm --import https://repo.mysql.com/RPM-GPG-KEY-mysql-2022第一步、下载MySQL 安装包&#xff1a; sudo wget h…
阅读更多...
Python 中的内存管理机制

Python 中的内存管理机制

Python 的内存管理机制主要由两个部分组成&#xff1a;垃圾回收机制和引用计数。 垃圾回收机制主要负责检测和回收不再被使用的内存。Python 使用的是自动垃圾回收机制&#xff0c;也就是说程序员不需要手动释放内存。Python 的垃圾回收机制采用了引用计数的方法来追踪和回收不…
阅读更多...
植物大战僵尸杂交版破解C++实现

植物大战僵尸杂交版破解C++实现

文章目录 前言准备工作&#xff1a;基地址与偏移UI界面设计和绑定项目模板总览图生成与实现信号处理1、阳光值更新:BTN12、三种钱币值更新:BTN2-BTN43、冷却刷新:BTN54、锁定阳光&#xff1a;check15、无冷却&#xff1a;check26、OnTimer&#xff08;&#xff09;和OnClose&am…
阅读更多...
git合并多个项目并保留提交版本记录

git合并多个项目并保留提交版本记录

目录 一、场景 二、合并步骤 1.本地新建 all 目录&#xff0c;并初始化 2.在 all 中添加 a&#xff0c;b&#xff0c;c 的远程分支 3.验证是否添加成功 4.在 all 目录下&#xff0c;获取 a, b,c 的 master 分支数据 5.合并项目并移动到子目录中 6.推送 all 的 master 分支…
阅读更多...
二开版微交易系统

二开版微交易系统

下载地址&#xff1a;二开版微交易系统
阅读更多...
集成学习概述

集成学习概述

概述 集成学习(Ensemble learning)就是将多个机器学习模型组合起来&#xff0c;共同工作以达到优化算法的目的。具体来讲&#xff0c;集成学习可以通过多个学习器相结合&#xff0c;来获得比单一学习器更优越的泛化性能。集成学习的一般步骤为&#xff1a;1.生产一组“个体学习…
阅读更多...
实战 | YOLOv10 自定义数据集训练实现车牌检测 (数据集+训练+预测 保姆级教程)

实战 | YOLOv10 自定义数据集训练实现车牌检测 (数据集+训练+预测 保姆级教程)

导读 本文主要介绍如何使用YOLOv10在自定义数据集训练实现车牌检测 (数据集训练预测 保姆级教程)。 YOLOv10简介 YOLOv10是清华大学研究人员在Ultralytics Python包的基础上&#xff0c;引入了一种新的实时目标检测方法&#xff0c;解决了YOLO以前版本在后处理和模型架构方面…
阅读更多...
规范系统运维：系统性能监控与优化的重要性与实践

规范系统运维：系统性能监控与优化的重要性与实践

在当今这个高度信息化的时代&#xff0c;企业的IT系统运维工作显得尤为关键。其中&#xff0c;系统性能监控和优化是运维工作中不可或缺的一环。本文旨在探讨规范系统运维中系统性能监控与优化的重要性&#xff0c;并分享一些实践经验和策略。 一、系统性能监控与优化的重要性…
阅读更多...
RAGFlow 学习笔记

RAGFlow 学习笔记

RAGFlow 学习笔记 0. 引言1. RAGFlow 支持的文档格式2. 嵌入模型选择后不再允许改变3. 干预文件解析​4. RAGFlow 与其他 RAG 产品有何不同&#xff1f; ​5. RAGFlow 支持哪些语言&#xff1f; ​6. 哪些嵌入模型可以本地部署&#xff1f; ​7. 为什么RAGFlow解析文档的时间比…
阅读更多...
自动化装箱封箱解决方案：深度探讨其优势及故障处理技巧

自动化装箱封箱解决方案：深度探讨其优势及故障处理技巧

在当今这个快节奏、高效率的时代&#xff0c;自动化装箱封箱解决方案以其独特的优势&#xff0c;正逐渐成为物流、仓储等行业的新宠。它不仅能大幅提升作业效率&#xff0c;还能显著降低人工成本&#xff0c;减少人为错误。星派将深度探讨自动化装箱封箱技术的显著优势&#xf…
阅读更多...
【Vue】练习-mutations的减法功能

【Vue】练习-mutations的减法功能

文章目录 一、需求二、完整代码 一、需求 步骤 二、完整代码 Son1.vue <template><div class"box"><h2>Son1 子组件</h2>从vuex中获取的值: <label>{{ $store.state.count }}</label><br><button click"handleA…
阅读更多...
C# 界面控件中英切换

C# 界面控件中英切换

编程软件:VS 2015 需求:界面有两个按钮&#xff0c;点击可以将界面上所有控件进行不同语言的切换。 一共两种方案&#xff0c;个人认为第二种方案使用范围更广&#xff08;这里以中英文切换为例&#xff09;。 方案一:如图所示&#xff0c;建立两个资源文件 将所需控件的中英…
阅读更多...
海思SS928（SD3403）部署YOLOv5-YOLOv7步骤详解

海思SS928（SD3403）部署YOLOv5-YOLOv7步骤详解

1. YOLO模型资料 本文档内容以yolov5-7.0工程、yolov5s模型为例。 a. 模型结构 详细的模型结构可以利用netron工具打开.pt或.onnx模型查看。 b. 模型参数即验证结果 其中，YOLOv5n、YOLOv5s、YOLOv5m、YOLOv5l、YOLOv5x为五种类型的预训练模型，其包含的检测类别相…
阅读更多...
利用Pandas进行数据清洗与过滤：Python实战指南

利用Pandas进行数据清洗与过滤：Python实战指南

利用Pandas进行数据清洗与过滤&#xff1a;Python实战指南 作为一个Python爱好者和数据分析从业者&#xff0c;我一直在探索如何利用Python来更高效地处理和分析数据。Python语言以其简单易学、功能强大的特点&#xff0c;成为了数据分析领域的宠儿。本文将分享一些实用的Pyth…
阅读更多...
2024 cicsn ezbuf

2024 cicsn ezbuf

文章目录 参考protobuf逆向学习复原结构思路exp 参考 https://www.y4ng.cn/posts/pwn/protobuf/#ciscn-2024-ezbuf protobuf 当时压根不知道用了protobuf这个玩意&#xff0c;提取工具也没提取出来&#xff0c;还是做题做太少了&#xff0c;很多关键性的结构都没看出来是pro…
阅读更多...
android 异屏同显---学习笔记

android 异屏同显---学习笔记

实现 Android 异屏同显（多个屏幕显示同样的画面）可以通过多种方法来完成，具体实现方式会根据你的需求和设备的支持情况有所不同。以下是几种常见的方法： 方法 1：使用 Cast SDK 如果你想要将内容投屏到智能电视或其他支持 Cast 的设备上，可以使用 Google Cast SDK。 主…
阅读更多...
Unity 集成 FMOD 音频管理插件 2.02

Unity 集成 FMOD 音频管理插件 2.02

Unity 集成 FMOD 音频管理插件 2.02 3. 集成教程&#xff1a;3.1 设置Unity项目3.2 设置FMOD项目3.3 设置 FMOD for Unity3.4 添加声音&#xff1a;卡丁车引擎3.5 添加声音&#xff1a;氛围3.6 添加声音&#xff1a;音乐3.7 删除现有音频3.8 下一步 10. 脚本 API 参考10.1 基础…
阅读更多...
Java锁的四种状态（无锁、偏向级锁、轻量级锁、重量级锁）

Java锁的四种状态（无锁、偏向级锁、轻量级锁、重量级锁）

介绍 首先&#xff0c;我们需要明确一点&#xff1a;偏向级锁、轻量级锁、重量级锁只针对synchronized 锁的状态总共有四种&#xff0c;级别由低到高依次为&#xff1a;无锁、偏向锁、轻量级锁、重量级锁。 这四种锁状态分别代表什么&#xff0c;为什么会有锁升级&#xff…
阅读更多...
在UI界面中实现3d人物展示

在UI界面中实现3d人物展示

简要原理（设置双摄像机）： 为需要展示的3D人物单独设置一个摄像机（只设置为渲染人物层级），主要摄像机的方向与人物方向一致，但摄像机需要需要旋转180，设置的角度自行进行微调创建一个Render Texture类型的组件用于存储摄像机渲染的内容UI上设置需要展示的图片区域，图片…
阅读更多...
最新文章

Copyright @ 2022~2023