【Linux】多线程4——线程同步/条件变量

1.Linux线程同步

1.1.同步概念与线程饥饿问题

先来理解同步的概念

  • 什么是线程同步

        在一般情况下，创建一个线程是不能提高程序的执行效率的，所以要创建多个线程。但是多个线程同时运行的时候可能调用线程函数，在多个线程同时对同一个内存地址进行写入，由于CPU时间调度上的问题，写入数据会被多次的覆盖，所以就要使线程同步。

同步就是协同步调，按预定的先后次序进行运行。如：你说完，我再说。

“同”字从字面上容易理解为一起动作，但其实不是，“同”字应是指协同、协助、互相配合。

        如进程、线程同步，可理解为进程或线程A和B一块配合，A执行到一定程度时要依靠B的某个结果，于是停下来，示意B运行；B依言执行，再将结果给A；A再继续操作。

        所谓同步，就是在发出一个功能调用时，在没有得到结果之前，该调用就不返回，同时其它线程也不能调用这个方法。按照这个定义，其实绝大多数函数都是同步调用（例如sin, isdigit等）。但是一般而言，我们在说同步、异步的时候，特指那些需要其他部件协作或者需要一定时间完成的任务。例如Window API函数SendMessage。该函数发送一个消息给某个窗口，在对方处理完消息之前，这个函数不返回。当对方处理完毕以后，该函数才把消息处理函数所返回的LRESULT值返回给调用者。

  • 同步： 在保证数据安全的前提下，让线程能够按照某种特定的顺序访问临界资源，从而有效避免饥饿问题，这就叫做同步。
  • 竞态条件： 因为时序问题，而导致程序异常，我们称之为竞态条件。
  • 线程饥饿问题

        首先需要明确的是，单纯的加锁是会存在某些问题的，如果个别线程的竞争力特别强，每次都能够申请到锁，但申请到锁之后什么也不做，所以在我们看来这个线程就一直在申请锁和释放锁，这就可能导致其他线程长时间竞争不到锁，引起饥饿问题。

        单纯的加锁是没有错的，它能够保证在同一时间只有一个线程进入临界区，但它没有高效的让每一个线程使用这份临界资源。

        现在我们增加一个规则，当一个线程释放锁后，这个线程不能立马再次申请锁，该线程必须排到这个锁的资源等待队列的最后。

        增加这个规则之后，下一个获取到锁的资源的线程就一定是在资源等待队列首部的线程，如果有十个线程，此时我们就能够让这十个线程按照某种次序进行临界资源的访问。

        例如，现在有两个线程访问一块临界区，一个线程往临界区写入数据，另一个线程从临界区读取数据，但负责数据写入的线程的竞争力特别强，该线程每次都能竞争到锁，那么此时该线程就一直在执行写入操作，直到临界区被写满，此后该线程就一直在进行申请锁和释放锁。而负责数据读取的线程由于竞争力太弱，每次都申请不到锁，因此无法进行数据的读取，引入同步后该问题就能很好的解决。

1.2.条件变量

我们怎么实现线程同步呢？这需要学习Linux的条件变量。

  • 什么是条件变量？该不会真就是1个变量吧！！！

千万不要被误导了，条件变量可不是变量， 条件变量是利用线程间共享的全局变量进行同步的一种机制，条件变量是用来描述某种资源是否就绪的一种数据化描述。

条件变量通常需要配合互斥锁一起使用。

        互斥量可以防止多个线程同时访问临界资源，而条件变量允许一个线程将某个临界资源的状态变化通知其他线程，在共享资源设定一个条件变量，如果共享资源条件不满足，则让线程到该条件变量下阻塞等待，当条件满足时，其他线程可以唤醒条件变量阻塞等待的线程。

        在线程之间有一种情况：线程A需要某个条件才能继续往下执行，如果该条件不成立，此时线程A进行阻塞等待，当线程B运行后使该条件成立后，则唤醒该线程A继续往下执行。

        在pthread库中，可以通过条件变量中，可以设定一个阻塞等待的条件，或者唤醒等待条件的线程。

        条件变量是利用线程间共享的全局变量进行同步的一种机制，条件变量是用来描述某种资源是否就绪的一种数据化描述。

条件变量是一种等待机制，每一个条件变量对应一个等待原因与等待队列。一般对于条件变量会有两种操作:

  1. wait操作 : 将自己阻塞在等待队列里，唤醒一个等待者或者开放锁的互斥访问
  2. singal 操作 : 唤醒一个等待的线程(等待队列为空的话什么也不做)

1.3.条件变量函数

1.3.1.初始化条件变量

POSIX提供了两种初始化条件变量的方法。

  • 第一种方法

初始化条件变量的函数叫做pthread_cond_init，该函数的函数原型如下：

int pthread_cond_init(pthread_cond_t *restrict cond, const pthread_condattr_t *restrict attr);

参数说明：

  • cond：需要初始化的条件变量。
  • attr：初始化条件变量的属性，一般设置为NULL即可。

返回值说明：

  • 条件变量初始化成功返回0，失败返回错误码。
  • 第二种方法

调用pthread_cond_init函数初始化条件变量叫做动态分配，除此之外，我们还可以用下面这种方式初始化条件变量，该方式叫做静态分配：

pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

这个相当于调用函数pthread_cond_init()初始化，并且参数attr为NULL。 

1.3.2.销毁条件变量

销毁条件变量的函数叫做pthread_cond_destroy，该函数的函数原型如下：

int pthread_cond_destroy(pthread_cond_t *cond);

参数说明：

  • cond：需要销毁的条件变量。

返回值说明：

  • 条件变量销毁成功返回0，失败返回错误码。

销毁条件变量需要注意：

  • 使用PTHREAD_COND_INITIALIZER初始化的条件变量不需要销毁。

1.3.3.等待条件变量满足

        条件变量就是为了与某个条件关联起来使用的，如果条件不满足，就等待(pthread_cond_wait) ，或者等待一段有限的时间(pthread_cond_timedwait) 。

POSIX提供了如下条件变量的等待接口：

        函数描述：这两个函数都是让指定的条件变量进入等待状态，其工作机制是先解锁传入的互斥量，再让条件变量等待，从而使所在线程处于阻塞状态。这两个函数返回时，系统会确保该线程再次持有互斥量(加锁)。

两个函数的区别：

  1. pthread_cond_wait函数调用成功后，会一直阻塞等待，直到条件变量被唤醒。
  2. 而 pthread_cond_timedwait 函数只会等待指定的时间，时间到了之后，条件变量仍未被唤醒的话，会返回一个错误码ETIMEDOUT，该错误码定义在<errno.h>头文件。

参数说明：

  • cond：需要等待的条件变量。
  • mutex：当前线程所处临界区对应的互斥锁。

返回值说明：

函数调用成功返回0，失败返回错误码。

1.3.4.唤醒等待

上面说完了条件等待，接下来介绍条件变量的唤醒。

调用完条件变量等待函数的线程处于阻塞状态，若要被唤醒，必须是其他线程来唤醒。

唤醒等待的函数有以下两个：

#include <pthread.h>
int pthread_cond_signal(pthread_cond_t *cond);
int pthread_cond_broadcast(pthread_cond_t *cond);

必须在互斥锁的保护下使用相应的条件变量。否则对条件变量的解锁有可能发生在锁定条件变量之前，从而造成死锁。 

        pthread_cond_signal 负责唤醒等待在条件变量上的一个线程，如果有多个线程等待，是唤醒哪一个呢？Linux内核会为每个条件变量维护一个等待队列，调用了 pthread_cond_wait 或 pthread_cond_timedwait 的线程会按照调用时间先后添加到该队列中。pthread_cond_signal会唤醒该队列的第一个。

        如果没有线程被阻塞在条件变量上，那么调用pthread_cond_signal()将没有作用。

        pthread_cond_broadcast，就是同时唤醒等待在条件变量上的所有线程。前面说过，条件等待的两个函数返回时，系统会确保该线程再次持有互斥量(加锁)，所有，这里被唤醒的所有线程都会去争夺互斥锁，没抢到的线程会继续等待，拿到锁后同样会从条件等待函数返回。所以，被唤醒的线程第一件事就是再次判断条件是否满足！

        由于pthread_cond_broadcast函数唤醒所有阻塞在某个条件变量上的线程，这些线程被唤醒后将再次竞争相应的互斥锁，所以必须小心使用pthread_cond_broadcast函数。

参数说明：

  • cond：唤醒在cond条件变量下等待的线程。

返回值说明：

  • 函数调用成功返回0，失败返回错误码。

使用示例：

我们先下面这样子的

#include <stdio.h>
#include <pthread.h>
#include<iostream>
#include<unistd.h>
using namespace std;int cnt=0;void* Count(void*args)
{pthread_detach(pthread_self());//分离线程long long number=(long long)args;while(1){cout<<"pthread: "<<number<<endl;sleep(3);}
}int main()
{for(long long i=0;i<5;i++){pthread_t tid;pthread_create(&tid,nullptr,Count,(void*)i);}while(1)sleep(1);
}

特别注意：64位平台下面，int类型是4字节，不能和void*指针类型（8字节）进行相互转换 ，所以这里使用long long

 

        多个执行流向显示器打印，就是往文件里写入，多线程或多进程往同一个文件写入，这个文件就是一种临界资源，不加保护的话，非常容易出现信息干扰。

#include <stdio.h>
#include <pthread.h>
#include<iostream>
#include<unistd.h>
using namespace std;int cnt=0;//全局变量
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;//互斥锁，不需要初始化和销毁
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;//条件变量,不需要初始化和销毁void* Count(void*args)
{pthread_detach(pthread_self());//分离线程long long number=(long long)args;while(1){pthread_mutex_lock(&mutex);//加锁//先不管临界资源的情况cout<<"pthread: "<<number<<" ,cnt :"<<cnt++<<endl;pthread_mutex_unlock(&mutex);//解锁sleep(1);}
}int main()
{for(long long i=0;i<5;i++){pthread_t tid;pthread_create(&tid,nullptr,Count,(void*)i);}while(1)sleep(1);
}

 

我们给打印这条语句加了锁，打印出来的结果也自然不会混乱了

好了，我今天想说的主角可不是屏幕，而是我们的++操作

我们接下来用上我们的条件变量

#include <stdio.h>
#include <pthread.h>
#include<iostream>
#include<unistd.h>
using namespace std;int cnt=0;//全局变量
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;//互斥锁，不需要初始化和销毁
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;//条件变量,不需要初始化和销毁void* Count(void*args)
{pthread_detach(pthread_self());//分离线程long long number=(long long)args;cout<<"pthread: "<<number<<" creat success !"<<endl;while(1){pthread_mutex_lock(&mutex);//加锁pthread_cond_wait(&cond,&mutex);//先让自己这个线程去条件变量cond的等待队列  //为什么填在这里？pthread_cond_wait让线程等待的时候会自动释放掉//先不管临界资源的情况cout<<"pthread: "<<number<<" ,cnt :"<<cnt++<<endl;pthread_mutex_unlock(&mutex);//解锁sleep(1);}
}int main()
{for(long long i=0;i<5;i++){pthread_t tid;pthread_create(&tid,nullptr,Count,(void*)i);usleep(1000);}sleep(3);cout<<"main thread ctrl begin:"<<endl;while(1){sleep(1);//每过1秒就唤醒1次pthread_cond_signal(&cond);//唤醒在cond的等待队列的1个线程，默认都是第1个cout<<"signal one thread..."<<endl;}
}

      此时我们会发现唤醒这4个线程时具有明显的顺序性，根本原因是当这若干个线程启动时默认都会在该条件变量下去等待，而我们每次都唤醒的是在当前条件变量下等待的头部线程，当该线程执行完打印操作后会继续排到等待队列的尾部进行wait，所以我们能够看到一个周转的现象。

我们可以唤醒所有线程

#include <stdio.h>
#include <pthread.h>
#include<iostream>
#include<unistd.h>
using namespace std;int cnt=0;//全局变量
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;//互斥锁，不需要初始化和销毁
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;//条件变量,不需要初始化和销毁void* Count(void*args)
{pthread_detach(pthread_self());//分离线程long long number=(long long)args;cout<<"pthread: "<<number<<" creat success !"<<endl;while(1){pthread_mutex_lock(&mutex);//加锁pthread_cond_wait(&cond,&mutex);//先让别的线程去等待队列  //为什么填在这里？pthread_cond_wait让线程等待的时候会自动释放掉//先不管临界资源的情况cout<<"pthread: "<<number<<" ,cnt :"<<cnt++<<endl;pthread_mutex_unlock(&mutex);//解锁sleep(1);}
}int main()
{for(long long i=0;i<5;i++){pthread_t tid;pthread_create(&tid,nullptr,Count,(void*)i);usleep(1000);}sleep(3);cout<<"main thread ctrl begin:"<<endl;while(1){sleep(1);pthread_cond_broadcast(&cond);//唤醒在cond的等待队列的1个线程，默认都是第1个cout<<"signal one thread..."<<endl;}
}

我为什么要让一个线程去休眠？

一定是临界资源没有就绪，没错，临界资源也是有状态的

你怎么知道临界资源是就绪还是不就绪的？你判断出来的！那判断是访问临界资源吗？ 是的，必须是的

        我们需要判断临界资源状态，就得访问临界资源，而我们的线程对临界资源是会修改的，这就注定了这个判断一定要在加锁和解锁之间，这样子别的线程就不能修改我们的临界资源，我们的判断结果也会是正确的

也就是必须是下面这种结构

 

void* Count(void*args)
{while(1){pthread_mutex_lock(&mutex);//加锁pthread_cond_wait(&cond,&mutex);//判断资源情况，pthread_mutex_unlock(&mutex);//解锁}
}

这也是我们为什么需要互斥量的原因 

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

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

相关文章

centos stream 9安装 Kubernetes v1.30 集群

centos stream 9安装 Kubernetes v1.30 集群

1、版本说明&#xff1a; 系统版本&#xff1a;centos stream 9 Kubernetes版本&#xff1a;最新版(v1.30) docker版本&#xff1a;27.1.1 节点主机名ip主节点k8s-master172.31.0.10节点1k8s-node1172.31.0.11节点2k8s-node2172.31.0.12 2、首先&#xff0c;使用Vagrant和Virt…
阅读更多...
前端缓存问题（浏览器缓存和http缓存）- 解决办法

前端缓存问题（浏览器缓存和http缓存）- 解决办法

问题描述&#xff1a;前端代码更新&#xff0c;但因浏览器缓存问题&#xff0c;导致页面源代码并未更新 查看页面源代码的方法&#xff1a;鼠标右键&#xff0c;点击查看页面源代码 如图&#xff1a; 解决方法&#xff1a; 注&#xff1a;每执行一步&#xff0c;就检查一下浏览…
阅读更多...
string indices must be integers

string indices must be integers

string indices must be integers 目录 string indices must be integers 【常见模块错误】 【解决方案】 常见原因及解决方法 具体案例分析 总结 欢迎来到英杰社区https://bbs.csdn.net/topics/617804998 欢迎来到我的主页&#xff0c;我是博主英杰&#xff0c;211科班出…
阅读更多...
Java1.1标准之重要特性及用法实例(十二)

Java1.1标准之重要特性及用法实例(十二)

简介&#xff1a; CSDN博客专家&#xff0c;专注Android/Linux系统&#xff0c;分享多mic语音方案、音视频、编解码等技术&#xff0c;与大家一起成长&#xff01; 新书发布&#xff1a;《Android系统多媒体进阶实战》&#x1f680; 优质专栏&#xff1a; Audio工程师进阶系列…
阅读更多...
kafka高性能的底层原理分析

kafka高性能的底层原理分析

目录 1.磁盘顺序写 2.零拷贝 3.数据压缩 4.消息批量处理 5.pageCache 6.稀疏索引 总结 Kafka是一种高吞吐量的分布式发布订阅消息系统&#xff0c;它可以处理消费者在网站中的所有动作流数据。那么他是如何做到高性能的呢&#xff0c;本篇文章从宏观上分析一下&#xff…
阅读更多...
C++——初识模板

C++——初识模板

前言 模板是C中的重大板块&#xff0c;是使C真正超越C语言的工具&#xff0c;在C模板没有设计出来之前其实C是没有那么被行业和社会所认可的&#xff0c;本节我们将初步了解C中的模板&#xff08;仅作大致讲解&#xff0c;具体的细枝末节将会再过几节讲解&#xff09;&#xf…
阅读更多...
Linuxnat网络配置

Linuxnat网络配置

&#x1f4d1;打牌 &#xff1a; da pai ge的个人主页 &#x1f324;️个人专栏 &#xff1a; da pai ge的博客专栏 ☁️宝剑锋从磨砺出&#xff0c;梅花香自苦寒来 ☁️运维工程师的职责&#xff1a;监…
阅读更多...
一维数组--最长平台

一维数组--最长平台

这道题目挺简单的&#xff0c;那你还想这么久&#xff01; 直接看代码&#xff01; #include<cstdio> long long n,a[100002],sum,b[100002],max-99999,j; int main(){scanf("%d",&n);scanf("%d",&a[1]);sum1;for(int i2;i<n;i){j;scan…
阅读更多...
【ESP32 IDF 定时器Timer】

【ESP32 IDF 定时器Timer】

目录 TIM定时器介绍硬件定时器和软件定时器硬件定时器基本参数硬件定时器的操作流程初始化硬件定时器设置报警注册回调函数使能和禁用定时器启动和停止定时器硬件定时器驱动代码调试 软件定时器使用软件定时器代码编写 TIM定时器 介绍 定时器是单片机内部集成&#xff0c;可以…
阅读更多...
鸿蒙HarmonyOS开发：多种内置弹窗及自定义弹窗的详细使用指南

鸿蒙HarmonyOS开发：多种内置弹窗及自定义弹窗的详细使用指南

文章目录 一、消息提示框&#xff08;showToast&#xff09;1、导入模块2、语法3、参数4、示例5、效果 二、对话框&#xff08;showDialog&#xff09;1、导入模块2、语法3、参数4、示例5、效果 三、警告弹窗&#xff08;AlertDialog&#xff09;1、语法2、参数3、AlertDialogP…
阅读更多...
STM32的GPIO输入输出方式设置示例

STM32的GPIO输入输出方式设置示例

1、GPIO口做基本的输入/输出口使用时&#xff0c;输入有上拉输入、下拉输入、浮空输入&#xff08;既无上拉电阻也无下拉电阻&#xff09;3种输入方式&#xff1b;输出有开漏输出、推挽输出2种输出方式。 2、示例 &#xff08;1&#xff09;示例1&#xff1a;GPIO做输出的设置…
阅读更多...
项目比赛经验分享：如何让即兴发言出彩

项目比赛经验分享：如何让即兴发言出彩

项目比赛经验分享&#xff1a;如何让即兴发言出彩 前言1. 顺势趁便法2. 词语撮要法3. 起承转合法4. 数字串连法结语 在项目管理和比赛的激烈竞争中&#xff0c;即兴发言往往成为展示个人魅力和团队精神的重要环节。如何在短时间内组织语言&#xff0c;表达清晰、有力的观点&…
阅读更多...
基于JSP、java、Tomcat三者的项目实战--校园交易网（3）主页

基于JSP、java、Tomcat三者的项目实战--校园交易网（3）主页

前文功能的实现 技术支持&#xff1a;JAVA、JSP 服务器&#xff1a;TOMCAT 7.0.86 编程软件&#xff1a;IntelliJ IDEA 2021.1.3 x64 前文三篇登录和注册功能的实现 基于JSP、java、Tomcat、mysql三层交互的项目实战--校园交易网&#xff08;1&#xff09;-项目搭建&#xf…
阅读更多...
Cisco路由器OSPF配置

Cisco路由器OSPF配置

Cisco路由器OSPF配置 本文已经迁移至 https://www.geekery.cn 本文档将详细介绍如何配置 OSPF&#xff08;开放最短路径优先&#xff09;协议&#xff0c;使用三个路由器&#xff1a;RA、RB 和 RC。一步一步说明每个路由器的配置、设置 IPv4 和 IPv6 地址的、配置OSPF 的启用以…
阅读更多...
Cocos Creator2D游戏开发-(1)初始化设置

Cocos Creator2D游戏开发-(1)初始化设置

初心: 做一款微信或者抖音小游戏,然后发布,对于我来说这是一个新的赛道; 写这些文档的原因,记录一下自己学习过程,下次用的时候方便找 cocos creator版本: 3.8.3 当前小游戏飞机大战教程来源于: 抖音: 禅影 chanying001 源码目录: https://www.kdocs.cn/l/caLr6XCbEfPa 创建一个…
阅读更多...
zeal 开发者离线文档工具

zeal 开发者离线文档工具

zeal是一款程序开发者不可或缺的离线文档查看器 下载地址 官网地址&#xff1a; windows版csdn下载(开箱即用含)&#xff1a;https://download.csdn.net/download/xzzteach/89588765 已离线 Android.docset Apache_HTTP_Server.docset Bash.docset Bootstrap_4.docset Bootst…
阅读更多...
selenium入门超详细教程——网页自动化操作

selenium入门超详细教程——网页自动化操作

文章目录 简介一、环境安装1.selenium安装2.安装浏览器驱动2.1 确定浏览器版本2.2 下载驱动 二、基础用法1.对页面进行操作1.1 初始化浏览器对象1.2 访问页面1.3 设置浏览器大小1.4 前进后退1.5 获取页面基础属性 2.定位页面元素3.模拟鼠标操作3.1 常用操作 4.模拟键盘操作4.1 …
阅读更多...
测评Copilot和ChatGPT-4o从PDF创建PPT功能

测评Copilot和ChatGPT-4o从PDF创建PPT功能

关于 Copilot 由 PDF 创建 PPT&#xff0c;之前已经发过几篇文档说明&#xff1a; Copilot for Microsoft 365 现已支持从PDF创建Word和PPT Copilot读PDF文献一键生成PPT&#xff0c;吓傻了导师 Copilot一键将PDF转为PPT&#xff0c;治好了我的精神内耗 今天来测评对比 Cop…
阅读更多...
在LabVIEW中使用Modbus

在LabVIEW中使用Modbus

NI 提供了三种主要机制与 Modbus 设备进行接口&#xff1a;(1) 高级 OPC 服务器&#xff0c;(2) Modbus I/O 服务器&#xff0c;以及 (3) 在 NI LabVIEW 软件中通过 LabVIEW 实时或 LabVIEW 数据记录与监控控制&#xff08;DSC&#xff09;模块引入的低级 Modbus API。 LabVIE…
阅读更多...
黑马Java零基础视频教程精华部分_8_学生管理系统

黑马Java零基础视频教程精华部分_8_学生管理系统

系列文章目录 文章目录 系列文章目录一、业务分析二、结合业务流程图编写代码1、Student.java代码&#xff1a;2、StudentSystem.java代码&#xff1a;3、标号&#xff08;‌label&#xff09;‌ 三、学生管理系统升级版 一、业务分析 需求文档如图所示&#xff1a; 根据需求…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023