【Linux系统化学习】线程互斥 | 互斥量(锁）

news/2024/11/29 21:26:27/

目录

多线程抢票问题

对问题的解释

代码的原子性

线程互斥

上述问题的解决方法

相关概念

互斥量（锁）

锁的定义和初始化

锁的销毁

加锁和解锁

加锁注意事项

使用锁注意事项

锁的原理

可重入与线程安全

概念

常见线程不安全的情况

常见线程安全的情况

常见不可重入的情况

常见可重入情况

可重入与线程安全的关系

可重入与线程安全的区别

多线程抢票问题

临近五一小长假，大多数人想着去外地进行旅游或者回趟老家；出行大多都会选择火车、动车等等，由于全国的出行人数众多；铁路局会在出行前两星期进行放票，大家在某一时刻进行抢票。这个看似简单的现实问题其中蕴含着很大的学问，我们可以把抢票的每个人看成一个线程，把票数看成整个进程中的公共资源。当满足票数大于零时，线程一直对这个资源进行瓜分；但是在实现代码后，我们会发现非常奇怪的问题。

我们可以编写一个简单的程序，模拟实现以下这个过程。

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
int ticket = 100;
//定义和初始化锁
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
void *route(void *arg)
{char *id = (char *)arg;while (1){// 临界区// 加锁pthread_mutex_lock(&mutex);if (ticket > 0){usleep(1000);printf("%s sells ticket:%d\n", id, ticket);ticket--;// 解锁pthread_mutex_unlock(&mutex);}else{// 解锁pthread_mutex_unlock(&mutex);break;}}
}
int main(void)
{pthread_t t1, t2, t3, t4;//局部初始化pthread_mutex_init(&mutex, NULL);pthread_create(&t1, NULL, route, "thread 1");pthread_create(&t2, NULL, route, "thread 2");pthread_create(&t3, NULL, route, "thread 3");pthread_create(&t4, NULL, route, "thread 4");pthread_join(t1, NULL);pthread_join(t2, NULL);pthread_join(t3, NULL);pthread_join(t4, NULL);//局部锁的销毁pthread_mutex_destroy(&mutex);
}

编译运行这个程序我们会发现一个奇怪的问题，最后某几个线程得到的票为负数；这个现象非常的不合理。

对问题的解释

代码的原子性

要解释这个现象我们还要知道代码的原子性；"代码的原子性"通常指的是代码的不可分割性或原子性操作。原子性操作是指在执行过程中不可中断的操作，要么全部执行成功，要么全部不执行。或者简单来说就是要么执行成功，要么执行失败。

原子性操作对于并发编程和多线程环境特别重要，因为在这些情况下，多个线程可能同时访问共享资源。如果操作不是原子性的，那么可能会出现竞态条件（Race Condition），导致数据不一致或其他问题。当然这只是一个概率巧合问题，问题虽小应用在现实生活中仍然是不安全的。

我们以编程语言中“++”操作符为例配合两个线程给大家做以详细的解释；++操作符看似是一句简单的语句，但是代码执行时形成汇编语言会转化为三条汇编语句。

首先定义的变量i实在内存中的，对内存中的数据进行操作时先将这个数据从内存转移到CPU中，在CPU中会对这个变量进行运算操作，最后运算操作完成时再将数据从CPU转移到内存中。

但是对于多线程来说会并发访问这个数据，然而每个线程在CPU中都有固定的调度时间，当某一个线程的调度时间到达时可能正处于这三条语句中的某一条语句，每个线程有含有单独的栈空间，线程调度切换时会将寄存器中产生的临时变量和上下文保存，当再次调度这个线程时会将上次保存的数据交给寄存器。因此，++操作符不是原子的，多线程并发访问会导致数据不一致。

注：我们可以将只含有一条汇编语句认为是原子的；

那么，对于判断语句是原子的还是非原子的呢？

很显然是非原子的，判断语句包含两步，第一步会先将数据转移到CPU中进行判断，第二步会返回比较结果。

因此对于上面的抢票代码我们就可以做出很好的解释（以两个线程为例）：当票数为1时，主线程将票数转移到CPU中进行判断，判断成功；当要返回判断结果时，恰好这个主线程的调度时间到了，保存临时数据和上下文切换新线程；新线程切换成功后，又进行同样的操作，将票数转移到CPU中进行判断，判断成功；恰好这个新线程的调度时间也到了又且回到主线程；主线程将上次的临时数据和上下文交给CPU进行处理，因为上次已经判断成功了，就将上次判断成功进行返回，将票数读到CPU中进行操作，然后对票数减一，将票数转移到内存中此时票数已经为零，主线程操作结束切换新线程；新线程又将自己上次的临时数据和上下文交给CPU，上次已经判断成功，又将上次返回。然后又从内存中读取已经为0的票数进行操作，这样我们就能得到上面的现象。

线程互斥

上述问题的解决方法

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

  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：锁的属性，一般为空指针

锁的销毁

  • 使用 PTHREAD_ MUTEX_ INITIALIZER 初始化的互斥量不需要销毁
  • 不要销毁一个已经加锁的互斥量
  • 已经销毁的互斥量，要确保后面不会有线程再尝试加锁
//销毁函数
int pthread_mutex_destroy(pthread_mutex_t *mutex)；

加锁和解锁

int pthread_mutex_lock(pthread_mutex_t *mutex);
int pthread_mutex_unlock(pthread_mutex_t *mutex);

返回值:成功返回0,失败返回错误号。（原子的)

调用 pthread_ lock 时，可能会遇到以下情况:

  • 互斥量处于未锁状态，该函数会将互斥量锁定，同时返回成功
  • 发起函数调用时，其他线程已经锁定互斥量，或者存在其他线程同时申请互斥量，但没有竞争到互斥量，
  • 那么pthread_ lock调用会陷入阻塞(执行流被挂起)，等待互斥量解锁。 

对抢票代码的改进：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
int ticket = 100;
//定义锁
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
void *route(void *arg)
{char *id = (char *)arg;while (1){//临界区//加锁pthread_mutex_lock(&mutex);if (ticket > 0){usleep(1000);printf("%s sells ticket:%d\n", id, ticket);ticket--;//解锁pthread_mutex_unlock(&mutex);}else{//解锁pthread_mutex_unlock(&mutex);break;}}
}
int main(void)
{pthread_t t1, t2, t3, t4;pthread_create(&t1, NULL, route, (void*)"thread 1");pthread_create(&t2, NULL, route, (void*)"thread 2");pthread_create(&t3, NULL, route, (void*)"thread 3");pthread_create(&t4, NULL, route, (void*)"thread 4");pthread_join(t1, NULL);pthread_join(t2, NULL);pthread_join(t3, NULL);pthread_join(t4, NULL);return 0;
}

对线程加锁后，将临界资源保护起来，多线程并发访问临界资源变成了串行访问临界资源，每个线程都互斥，这样减少了程序运行的效率却提高了程序的安全性。

加锁注意事项

  1. 我们要尽可能的给少的代码块加锁
  2. 一般加锁，都是给临界区加锁

使用锁注意事项

  1. 锁虽然也是公共资源，但是申请锁本身是安全的；因为申请锁是原子的，要么申请成功，要么申请失败。
  2. 申请使用锁时不要给某个线程搞特殊不加锁，因为这样依然会又概率面临上面程序产生的问题。
  3. 根据互斥的定义任何时刻，任何时刻只允许一个线程申请锁成功。申请锁失败的线程，会被阻塞等待。
  4. 一个线程临界区访问临界资源的时候，也可能发生切换；切换后的线程将不会申请到锁，因此就不会在临界区访问临界资源。
  5. 个别系统中上面的代码运行后会有只有一个线程获取到了所有的票，表示这个线程对锁的竞争能力比较强，这个问题为多线程饥饿 ，要让线程在执行是具有一定的顺序。（线程同步）

锁的原理

为了实现互斥锁操作,大多数体系结构都提供了swap或exchange指令,该指令的作用是把寄存器和内存单元的数据相交换,由于只有一条指令,保证了原子性,即使是多处理器平台,访问内存的 总线周期也有先后,一个处理器上的交换指令执行时另一个处理器的交换指令只能等待总线周期。

可重入与线程安全

概念

  • 线程安全：多个线程并发同一段代码时，不会出现不同的结果。常见对全局变量或者静态变量进行操作，并且没有锁保护的情况下，会出现该问题。
  • 重入：同一个函数被不同的执行流调用，当前一个流程还没有执行完，就有其他的执行流再次进入，我们称之为重入。一个函数在重入的情况下，运行结果不会出现任何不同或者任何问题，则该函数被称为可重入函数，否则，是不可重入函数。

常见线程不安全的情况

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

常见线程安全的情况

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

常见不可重入的情况

  1. 调用了malloc/free函数，因为malloc函数是用全局链表来管理堆的
  2. 调用了标准I/O库函数，标准I/O库的很多实现都以不可重入的方式使用全局数据结构
  3. 可重入函数体内使用了静态的数据结构

常见可重入情况

  1. 不使用全局变量或静态变量
  2. 不使用用malloc或者new开辟出的空间
  3. 不调用不可重入函数
  4. 不返回静态或全局数据，所有数据都有函数的调用者提供
  5. 使用本地数据，或者通过制作全局数据的本地拷贝来保护全局数据 

可重入与线程安全的关系

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

可重入与线程安全的区别

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

今天对Linux下线程互斥和锁的分享到这就结束了，希望大家读完后有很大的收获，也可以在评论区点评文章中的内容和分享自己的看法；个人主页还有很多精彩的内容。您三连的支持就是我前进的动力，感谢大家的支持！！! 


http://www.ppmy.cn/news/1431276.html

相关文章

Vs Code npm install 报错解决方法

Vs Code npm install 报错解决方法

用的人家的前端框架发现是封装过的&#xff0c;要修改人家前端的话还得把前端源码放在Vs Code 上运行&#xff0c;后端放在IDEA上运行&#xff0c;然后前后端并行开发&#xff0c;在配置前端环境时遇到&#xff1a; npm install 这个的原因是我把node下载到D盘了权限不够框框爆…
阅读更多...
Redis入门到通关之Redis数据结构-Hash篇

Redis入门到通关之Redis数据结构-Hash篇

文章目录 ☃️ 概述☃️底层实现☃️源码☃️其他 欢迎来到 请回答1024 的博客 &#x1f353;&#x1f353;&#x1f353;欢迎来到 请回答1024的博客 关于博主&#xff1a; 我是 请回答1024&#xff0c;一个追求数学与计算的边界、时间与空间的平衡&#xff0c;0与1的延伸的后…
阅读更多...
图论基础知识 深度搜索（DFS，Depth First Search）,广度搜索（BFS，Breathe First Search）

图论基础知识 深度搜索（DFS，Depth First Search）,广度搜索（BFS，Breathe First Search）

图论基础知识 学习记录自代码随想录 dfs 与 bfs 区别 dfs是沿着一个方向去搜&#xff0c;不到黄河不回头&#xff0c;直到搜不下去了&#xff0c;再换方向&#xff08;换方向的过程就涉及到了回溯&#xff09;。 bfs是先把本节点所连接的所有节点遍历一遍&#xff0c;走到下…
阅读更多...
线性回归、逻辑回归

线性回归、逻辑回归

线性回归是一种统计分析方法，它利用数理统计中的回归分析来确定两种或两种以上变量间相互依赖的定量关系。这种分析方法在生活中有着广泛的应用场景，如经济学、市场营销、医学研究、教育评估以及人力资源管理等。其表达形式通常为y = wx+e，其中y是因变量，x是自变量，w是权重…
阅读更多...
Excel遇上VBA，开启智能联网新篇章！

Excel遇上VBA，开启智能联网新篇章！

EXCEL可联网了竖屏 你是否曾经因为Excel中的数据更新不及时而烦恼&#xff1f;是否因为手动整理网络数据而疲惫不堪&#xff1f;现在&#xff0c;有了VBA&#xff08;Visual Basic for Applications&#xff09;的加持&#xff0c;Excel也能轻松联网&#xff0c;实现数据自动更…
阅读更多...
分享三个转换速度快、准确率高的视频转文字工具

分享三个转换速度快、准确率高的视频转文字工具

想要直接将视频转换成文字&#xff0c;转换工具很重要&#xff01;给大家分享三个转换速度快、准确率高的视频转文字工具&#xff0c;轻松完成转换。 1.网易见外 https://sight.youdao.com/ 网易家的智能转写翻译服务工作站&#xff0c;网页端就可以直接使用&#xff0c;支持视…
阅读更多...
Kafka - Kafka 为啥抛弃 Zookeeper？

Kafka - Kafka 为啥抛弃 Zookeeper？

Kafka 为什么要抛弃 ZooKeeper&#xff1f;取代方案是怎样的&#xff1f;因为确实有优化空间。 Zookeeper加kafka 的架构&#xff0c;有三层角色&#xff1a; zookeeper &#xff0c;提供基础的状态持久化和状态通知服务 controller &#xff0c;基于zookeeper提供的服务&…
阅读更多...
制造数字化“管理套路”

制造数字化“管理套路”

在当今竞争激烈的市场环境中&#xff0c;制造企业始终关心三个核心问题&#xff1a;生产效率、产品质量、成本控制&#xff0c;所以许多企业渴望加强对生产过程的管理控制。 生产过程是一个相对复杂的过程&#xff0c;涉及到多个环节和因素。从原材料的采购到产品的设计、生产…
阅读更多...
最新文章

Copyright @ 2022~2023