Linux线程（二）线程互斥

目录

一、为什么需要线程互斥

二、线程互斥的必要性

三、票务问题举例（多个线程并发的操作共享变量引发问题）

四、互斥锁的用法

1.互斥锁的原理

2、互斥锁的使用

1、初始化互斥锁

2、加锁和解锁

3、销毁互斥锁（动态分配时需要）

五、使用互斥锁改进票务问题

六、可重入与线程安全

 1、可重入（Reentrant）

2、线程安全（Thread Safety）

上篇文章我们讲解了线程的概念以及线程的基本操作：
Linux线程（一）初识线程

这篇文章我们来讲解一下线程互斥的内容。

一、为什么需要线程互斥

        当多个线程试图同时修改同一份数据时，可能会导致数据不一致、竞态条件等问题。

当两个或多个线程同时访问和修改同一个共享资源时，如果没有适当的同步控制，可能会导致数据处于不一致的状态。例如，一个线程正在读取某个变量的同时，另一个线程可能正在修改这个变量，最终结果可能既不是原始值也不是任何一个线程期望修改后的值，造成不可预料的行为。（后面会举例说明）

所以就引出了线程互斥 ：
在Linux系统中，线程互斥是一种确保多个线程在访问共享资源时不会产生冲突的机制。这是通过使用互斥锁（Mutex）来实现的，它是防止并发执行线程同时进入临界区（即访问共享资源的代码段）的一种同步原语。

二、线程互斥的必要性

线程互斥是确保多线程环境下程序正确性、稳定性和可预测性的关键手段，通过限制对共享资源的同时访问，避免了并发执行可能引发的各种问题：

避免数据竞争（Data Race）：当两个或多个线程同时访问和修改同一个共享资源时，如果没有适当的同步控制，可能会导致数据处于不一致的状态。例如，一个线程正在读取某个变量的同时，另一个线程可能正在修改这个变量，最终结果可能既不是原始值也不是任何一个线程期望修改后的值，造成不可预料的行为。

确保数据一致性：互斥机制确保了在任何时候，最多只有一个线程可以修改共享资源。这样可以保证每次对共享数据的修改都是完整且原子的，从而维护了数据的一致性。

预防竞态条件（Race Condition）：竞态条件是指程序的输出依赖于非确定性的线程执行顺序。没有互斥锁，即使程序逻辑正确，由于线程调度的不确定性，也可能导致错误的结果。比如经典的“票务问题”，如果不使用互斥锁，多个线程同时减去票数可能会导致卖出超过实际存在的票数。

实现同步点：除了防止并发访问带来的问题，互斥锁还可以作为线程间的同步工具，用于控制线程执行的顺序。例如，一个线程可能需要等待另一个线程完成特定任务后才能继续执行。

保护资源的完整性：某些资源（如文件、数据库连接、硬件设备等）可能不支持同时访问，或者同时访问会导致错误或损坏。互斥锁确保这些资源在被一个线程使用时，其他线程不能访问，从而保护了资源的完整性。

三、票务问题举例（多个线程并发的操作共享变量引发问题）

我们来看以下代码，多个线程访问一个全局变量ticket来模拟抢票，ticket就是共享变量：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
int ticket=100;void *route(void* arg)
{char *id=(char*)arg;while(1){if(ticket>0){usleep(1);printf("%s sells ticket:%d\n",id,ticket);ticket--;}else{break;}}
}int main()
{pthread_t t1,t2,t3,t4;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);return 0;
}

运行后发现

 

票数竟然出现了0和-1，显然是不符合预期的。

每个线程在检查ticket变量是否大于1后，直接进行减操作和打印，没有确保在这两个操作之间没有其他线程也进行了同样的检查和操作。这导致了多个线程可能几乎同时判断ticket大于1，并都执行减1操作，造成票数卖超的错误。

多个线程直接读写共享变量ticket而没有加锁保护，这违反了线程安全原则。当一个线程正在读取ticket的值时，另一个线程可能正在修改它，导致读取到的是不一致或中间状态的数据。

-- 操作并不是原子操作，而是对应三条汇编指令：
load ：将共享变量ticket从内存加载到寄存器中
可能同时有几个线程判断了ticket>0,并进行了ticket--操作，但是这个时候ticket的值已经被其他线程修改，这个时候就造成了共享变量的数据错误。
update : 更新寄存器里面的值，执行-1操作
store ：将新值，从寄存器写回共享变量ticket的内存地址

解决这些问题的关键是在访问共享资源（这里是ticket变量）之前使用互斥锁（Mutex），确保同一时间只有一个线程能执行临界区内的代码，从而避免了数据竞争和竞态条件，确保了线程安全。 

四、互斥锁的用法

1.互斥锁的原理

加锁（Lock）：当一个线程想要进入临界区时，它会尝试获取互斥锁。如果锁未被其他线程持有，该线程将成功获取锁并进入临界区。

解锁（Unlock）：完成对共享资源的操作后，线程会释放互斥锁，允许其他等待中的线程有机会获取锁并访问资源。

2、互斥锁的使用

在Linux中，使用POSIX线程库（pthread）来处理线程和互斥锁。以下是基本的使用步骤：

1、初始化互斥锁

静态初始化：pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
动态初始化：int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr);
参数：
mutex：要初始化的互斥量
attr：NULL

2、加锁和解锁

int pthread_mutex_lock(pthread_mutex_t *mutex);
int pthread_mutex_unlock(pthread_mutex_t *mutex);
返回值:成功返回0,失败返回错误号
调用 pthread_ lock 时，可能会遇到以下情况 :
互斥量处于未锁状态，该函数会将互斥量锁定，同时返回成功
发起函数调用时，其他线程已经锁定互斥量，或者存在其他线程同时申请互斥量，但没有竞争到互斥量，那么pthread_ lock调用会陷入阻塞(执行流被挂起)，等待互斥量解锁。

3、销毁互斥锁（动态分配时需要）

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

五、使用互斥锁改进票务问题

通过在访问和修改ticket变量前后分别调用pthread_mutex_lock()和pthread_mutex_unlock()，确保了在任何时刻只有一个线程能进行售票操作，从而解决了线程间的数据竞争问题，保证了票数的准确减少，避免了超卖现象。

代码示例：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
int ticket=100;
pthread_mutex_t mutex;
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--;}else{// 释放锁并跳出循环pthread_mutex_unlock(&mutex);break;}pthread_mutex_unlock(&mutex);}
}int main()
{// 初始化互斥锁pthread_mutex_init(&mutex, NULL);pthread_t t1,t2,t3,t4;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);return 0;
}

运行后发现保证了票数的准确减少，避免了超卖现象。

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

六、可重入与线程安全

 1、可重入（Reentrant）

定义：可重入指的是一个函数或一段代码可以在任意时刻被中断，然后再次进入并正确执行，即使在之前调用还未完成的情况下也是如此。对于可重入代码，最重要的是它的内部状态不会因多次调用而受损，且不依赖于外部状态或存储。

特点：

  • 不使用静态或全局变量存储状态信息。
  • 不使用用malloc或者new开辟出的空间
  • 如果必须使用全局数据，那么这些数据必须是只读的或能以线程安全的方式修改。
  • 函数不依赖于任何外部资源的状态，或能确保外部资源访问的线程安全性。
  • 递归调用是可重入的一个特例。

2、线程安全（Thread Safety）

定义：线程安全指多个线程同时访问（包括读取和写入）同一段代码或数据时，仍然能够保持正确的执行结果，不会引发数据不一致、崩溃或其他未定义行为。这意味着代码需要采取适当的同步措施（如互斥锁、信号量等）来防止数据竞争和竞态条件。

特点：

  • 通过同步机制确保共享资源的访问是互斥的，防止数据竞争。
  • 可能通过加锁机制来实现，但这也会引入潜在的死锁和性能开销。
  • 线程安全的代码在多线程环境下不需要外部干预即可安全运行。

关系：

  • 交集：可重入代码通常是线程安全的，因为它不依赖于全局状态，减少了并发访问的冲突点。
  • 区别：并非所有线程安全的代码都是可重入的。例如，一个使用了锁来保护共享资源的函数，虽然线程安全（因为一次只有一个线程可以修改资源），但如果在锁内调用自己（递归调用），可能会导致死锁，因此不是可重入的。

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

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

相关文章

贝壳面试：MySQL联合索引，最左匹配原则是什么？

贝壳面试：MySQL联合索引，最左匹配原则是什么？

尼恩说在前面 在40岁老架构师 尼恩的读者交流群(50)中&#xff0c;最近有小伙伴拿到了一线互联网企业如得物、阿里、滴滴、极兔、有赞、希音、百度、网易、美团的面试资格&#xff0c;遇到很多很重要的面试题&#xff1a; 1.谈谈你对MySQL联合索引的认识&#xff1f; 2.在MySQ…
阅读更多...
HTML【常用的标签】、CSS【选择器】

HTML【常用的标签】、CSS【选择器】

day45 HTML 继day44&#xff0c;w3cschool 常用的标签 k) 表格 表格由 table 标签来定义。每个表格均有若干行&#xff08;由 tr 标签定义&#xff09;&#xff0c;每行被分割为若干单元格&#xff08;由 标签定义&#xff09;。字母 td指表格数据&#xff08;table data&…
阅读更多...
java中的并发编程

java中的并发编程

1、上下文切换 即使是单核处理器也支持多线程执行代码&#xff0c;CPU通过给每个线程分配CPU时间片来实现 这个机制。这个时间片特别短&#xff0c;一般是几十毫秒&#xff0c;所以会让我们觉得好多任务同时进行。 CPU通过时间片分配算法来循环执行任务&#xff0c;当前任务执…
阅读更多...
Java----数组的定义和使用

Java----数组的定义和使用

1.数组的定义 在Java中&#xff0c;数组是一种相同数据类型的集合。数组在内存中是一段连续的空间。 2.数组的创建和初始化 2.1数组的创建 在Java中&#xff0c;数组创建的形式与C语言又所不同。 Java中数组创建的形式 T[] 数组名 new T[N]; 1.T表示数组存放的数据类型…
阅读更多...
【姿态解算与滤波算法】

【姿态解算与滤波算法】

姿态解算 一、主线 姿态表示方式&#xff1a;矩阵表示&#xff0c;轴角表示&#xff0c;欧拉角表示&#xff0c;四元数表示。 惯性测量单元IMU&#xff08;Inertial Measurement Unit&#xff09;&#xff1a;MPU6050芯片&#xff0c;包含陀螺仪和加速度计&#xff0c;分别测…
阅读更多...
2.前端路由的配置和使用

2.前端路由的配置和使用

一&#xff0c;路由的作用 路由的作用就是将页面文件跟URL地址形成对应匹配 二&#xff0c;如何安装路由 这里我们采用pnpm的方式在项目中执行 pnpm install vue-routernext --save三&#xff0c;路由如何使用 首先创建一个我们需要访问的页面文件&#xff0c;这里我先创建…
阅读更多...
HTTP超时时间设置

HTTP超时时间设置

在进行超时时间设置之前我们需要了解一次http请求经历的过程 浏览器进行DNS域名解析&#xff0c;得到对应的IP地址根据这个IP&#xff0c;找到对应的服务器建立连接&#xff08;三次握手&#xff09;建立TCP连接后发起HTTP请求&#xff08;一个完整的http请求报文&#xff09;服…
阅读更多...
安卓apk 脚本判断32位和64位兼容，还是纯64位

安卓apk 脚本判断32位和64位兼容，还是纯64位

安卓工程 打包 32位和64位说明 ndk {// abiFilters armeabi,arm64-v8a 32位和64位// abiFilters arm64-v8a 纯64位} 常用类型说明 armeabi-v7a 第7代及以上的ARM处理器&#xff08;ARM32位&#xff09;&#xff0c;市面上大多数手机使用此CPU类型。 arm64-v8a 第8代、64位A…
阅读更多...
探讨 vs2019 c++ 里函数指针与函数类型在使用上的语法区别

探讨 vs2019 c++ 里函数指针与函数类型在使用上的语法区别

&#xff08;1&#xff09;咱们可以用 decltype &#xff08;&#xff09; 来判断函数的类型。但以这个类型定义有用的可指向已存在函数的变量&#xff0c;却行不通。测试如下&#xff1a; 如果把上面的注释去掉会报错&#xff1a; 所以函数类型只有语法意义。但在使用上没有函…
阅读更多...
初识java--javaSE(3)--方法，递归，数组，

初识java--javaSE(3)--方法，递归，数组，

文章目录 一 方法的使用1.1 什么是方法&#xff1f;main方法注意事项 1.2 方法的调用嵌套调用在方法调用时形参与实参的关系&#xff1a; 1.3 方法的重载方法重载的意义&#xff1f;总结方法重载&#xff1a;方法签名&#xff1a; 二 递归什么是递归&#xff1f;递归的精髓&…
阅读更多...
任务：单域，域树的搭建

任务：单域，域树的搭建

一、单域&#xff1a; 搭建所需的系统&#xff1a;win2016 sever&#xff0c;win10 1.在创建域前&#xff0c;先设置静态ip 先查看win2016 sever的IP&#xff0c; ip&#xff1a;192.168.154.133 网关&#xff1a;192.168.154.2 DNS服务器&#xff1a;192.168.154.2 设置…
阅读更多...
嵌入式基础课程配套电机FOC伺服电机开发板AT32F403磁编码IMU姿态

嵌入式基础课程配套电机FOC伺服电机开发板AT32F403磁编码IMU姿态

嵌入式基础课程配套电机FOC伺服电机开发板AT32F403磁编码IMU姿态 带你入门嵌入式有二十多年开发经验的老技骨做技术支持整个开发包硬件包括电机2205&#xff0c;支持12V到24V宽输入&#xff0c;配套12V2A电源。包装原理图和PCB嵌入式软件嵌入式基础课程 带你入门嵌入式 电机FO…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023