Linux线程安全(二)条件变量实现线程同步

目录

条件变量

条件变量初始化和唤醒

键盘触发条件变量唤醒线程demo

条件变量的等待

条件变量定时等待demo

条线变量实现多线程间的同步


条件变量

条件变量是为了控制多个线程的同步工作而设计的

比如说一个系统中有多个线程的存在但有且仅有一个线程在工作,我们需要等待这个线程执行完任务之后然后唤醒另一个线程执行另外一个任务,

那这个时候“正在工作的这个线程执行完任务”就是一个条件变量,等这个条件变量触发之后正在工作的线程就会休眠,然后新的线程会启动。
 

条件变量初始化和唤醒

#include <pthread.h>

//销毁条件变量                                                                                                                                    int pthread_cond_destroy(pthread_cond_t *cond);  

//初始化条件变量
int pthread_cond_init(pthread_cond_t *restrict cond,
                       const pthread_condattr_t *restrict attr); 

cond:条件变量

attr:属性默认为 NULL

返回值: 成功 0                                                                                                                                                  失败 -1

#include <pthread.h>

//随机唤醒一个等待的线程                                                                                                                int pthread_cond_signal(pthread_cond_t *cond);

//唤醒所有正在等待的线程                                                                                                                 int pthread_cond_broadcast(pthread_cond_t *cond);    

键盘触发条件变量唤醒线程demo
#include <stdio.h>
#include <pthread.h>pthread_cond_t cond;
pthread_mutex_t mutex;int n = 0;void *task(void *arg)
{while (1){printf("%ld 线程等待条件\n", pthread_self());pthread_cond_wait(&cond, &mutex);if (n == 1){n = 0;printf("%ld 线程被唤醒,执行任务\n", pthread_self());}}
}int main()
{// 初始化锁与条件变量pthread_cond_init(&cond, NULL);pthread_mutex_init(&mutex, NULL);// 创建一个线程pthread_t tid;pthread_create(&tid, NULL, task, NULL);pthread_create(&tid, NULL, task, NULL);pthread_create(&tid, NULL, task, NULL);pthread_create(&tid, NULL, task, NULL);while (1){printf("1.唤醒随机一个线程  2.唤醒所有线程\n");int n = 0;scanf("%d", &n);if (n == 1){pthread_cond_signal(&cond); // 唤醒随机一个}else if (n == 2){pthread_cond_broadcast(&cond); // 唤醒所有}}
}
条件变量的等待

#include <pthread.h>

//定时等待
int pthread_cond_timedwait(pthread_cond_t *restrict cond,
                                                pthread_mutex_t *restrict mutex,
                                                const struct timespec *restrict abstime);

//一直等待
int pthread_cond_wait(pthread_cond_t *restrict cond,
                                       pthread_mutex_t *restrict mutex);

cond:条件变量

mutex:互斥锁

abstime:定时器

返回值:


条件变量定时等待demo
#include <stdio.h>
#include <pthread.h>
#include <time.h>pthread_cond_t cond;void *task(void *arg)
{while (1){printf("输入任意键唤醒线程\n");getchar();pthread_cond_signal(&cond);}
}int main()
{// 0.初始化互斥锁pthread_mutex_t mutex;pthread_mutex_init(&mutex, NULL);// 1.初始化条件变量int ret = pthread_cond_init(&cond, NULL);if (ret < 0){perror("初始化条件变量失败\n");}// 创建一个线程pthread_t tid;pthread_create(&tid, NULL, task, NULL);// 2.开启定时等待while (1){// 设置时间struct timespec ts;//clock_gettime()获取时间函数//CLOCK_REALTIME:系统实时时间,可以从网络同步,也可以用户自行更改clock_gettime(CLOCK_REALTIME, &ts); #if 0  //timespec结构体,tv_sec为秒
struct timespec
{__time_t tv_sec;    /* Seconds.  秒*/__syscall_slong_t tv_nsec;  /* Nanoseconds.纳秒*/      
}           
#endifts.tv_sec += 5;                     // 时间增加 5 秒printf("开启定时等待5秒\n");//pthread cond wait函数的返回值为0,代表成功等待条件变量并且收到了通知。//如果返回值是一个非零值,则表示函数运行出现了错误//需要根据错误码进行处理。int ret = pthread_cond_timedwait(&cond, &mutex, &ts);printf("等待结束 %d\n", ret);  //超时返回值110}
}

条线变量实现多线程间的同步

利用条件变量使三个线程轮流运作,线程1执行完之后执行线程2,线程2执行完之后执行线程3,线程3执行完之后重新执行线程1.

#include <stdio.h>
#include <pthread.h>// 定义三个条件
pthread_cond_t first;  // 条件1
pthread_cond_t second; // 条件2
pthread_cond_t third; // 条件3pthread_mutex_t mutex;void *task(void *arg)
{while (1){pthread_cond_wait(&third, &mutex);printf("线程1运行\n");pthread_cond_signal(&first);}
}void *task1(void *arg)
{while (1){pthread_cond_wait(&first, &mutex);printf("线程2运行\n");pthread_cond_signal(&second);}
}void *task2(void *arg)
{while (1){pthread_cond_wait(&second, &mutex);printf("线程3运行\n");pthread_cond_signal(&third);}
}int main()
{// 初始化条件变量与线程锁pthread_mutex_init(&mutex, NULL);pthread_cond_init(&first, NULL);pthread_cond_init(&second, NULL);pthread_cond_init(&third, NULL);// 创建三个任务线程pthread_t tid;pthread_create(&tid, NULL, task, NULL);pthread_t tid1;pthread_create(&tid1, NULL, task1, NULL);pthread_t tid2;pthread_create(&tid2, NULL, task2, NULL);while (1){printf("输入任意键线程开始工作\n");getchar();pthread_cond_signal(&third);}
}

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

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

相关文章

如何在浏览器中打开预览pdf,而不是下载

背景 上传了pdf文件之后&#xff0c;点击查看&#xff0c;跳转pdf的url&#xff0c;期望是浏览器中预览&#xff0c;而不是直接下载 原理 需要pdf资源url的响应头是下面下面这2个属性 Content-Type: application/pdf Content-Disposition: inline; 如何做 如果pdf资源服务…

leetcode hot100【LeetCode 230. 二叉搜索树中第K小的元素】java实现

LeetCode 230. 二叉搜索树中第K小的元素 题目描述 给定一个二叉搜索树的根节点 root&#xff0c;和一个整数 k&#xff0c;请你找出其中第 k 小的节点。 注意&#xff1a; 题目保证 k 的有效性。 示例&#xff1a; 给定二叉搜索树&#xff1a; 5/ \3 7/ \ \ 2 4 …

面对大模型,我是智者还是智障?基于个人能力量化问题测试!

目录 一、背景二、过程第一问&#xff1a;一个人拥有什么样的能力&#xff0c;可以在每天的工作生活中深度思考&#xff0c;并且能阶段性的突破自己的认知&#xff0c;不断迭代&#xff1f; 另外还可以再自己认知层次的基数上&#xff0c;做到思想上移和行动下移的结果&#xf…

python的lambda实用技巧

lambda表达式 lambda表达式是一种简化的函数表现形式&#xff0c;也叫匿名函数&#xff0c;可以存在函数名也可以不存在。 使用一行代码就可以表示一个函数&#xff1a; # 格式 lambda arg[参数] : exp[表现形式] # 无参写法 lambda : "hello" # 一般写法 lambda …

LeetCode72:编辑距离

题目链接&#xff1a;72. 编辑距离 - 力扣&#xff08;LeetCode&#xff09; 代码如下&#xff1a; class Solution { public:int minDistance(string word1, string word2) {vector<vector<int> > dp(word1.size() 1, vector<int>(word2.size() 1));for…

复现第一周24

1.[SWPUCTF 2021 新生赛]gift_F12 1&#xff09;打开题目 2&#xff09;看源码 3&#xff09;直接ctrl&#xff0b;f搜索flag 2.[SWPUCTF 2021 新生赛]nc签到 1&#xff09;开题 2&#xff09;下载附件用记事本打开 3&#xff09;打开kali使用nc连接代码 输入l\s命令绕过黑名…

LSTM,全称长短期记忆网络(Long Short-Term Memory),是一种特殊的循环神经网络(RNN)结构

关于lstm超参数设置&#xff0c;每个参数都有合适的范围&#xff0c;超过这个范围则lstm训练不再有效&#xff0c;loss不变&#xff0c;acc也不变 LSTM&#xff0c;全称长短期记忆网络&#xff08;Long Short-Term Memory&#xff09;&#xff0c;是一种特殊的循环神经网络&am…

「Mac畅玩鸿蒙与硬件8」鸿蒙开发环境配置篇8 - 应用依赖与资源管理

本篇将介绍如何在 HarmonyOS 项目中高效管理资源文件和依赖&#xff0c;以确保代码结构清晰并提升应用性能。资源管理涉及图片、字符串、多语言文件等&#xff0c;通过优化文件加载和依赖管理&#xff0c;可以显著提升项目的加载速度和运行效率。 关键词 资源管理应用依赖优化…

15分钟学 Go 小项目:Web API

Web API 在现代应用开发中&#xff0c;Web API&#xff08;应用程序编程接口&#xff09;是实现系统间交互的关键。通过理解HTTP协议、路由、RESTful设计原则&#xff0c;我们可以设计出高效、可维护的API。接下来&#xff0c;我们将深入探讨这些主题&#xff0c;并以一个简单…

Android SDK Version 33: ActivityCompat.requestPermissions不弹框

文章目录 异常现象原因 异常现象 使用Android进行权限判断时&#xff0c;ActivityCompat.requestPermissions不弹框。API为33 原因 从API33开始&#xff0c;为了优化用户体验&#xff0c;只有App全部加载完成并可用后&#xff0c;才会弹授权框。也就说&#xff0c;不能在onC…

软件评测第二期

《遥远的救世主》&#xff0c;自己得想办法&#xff0c;不断地救赎自己了&#xff0c;同时开源竞争&#xff0c;开源竞争&#xff08;自己没有办法完全掌握技术的时候就开源掉&#xff0c;培养出更多的技术依赖&#xff0c;让更多人完善你的技术&#xff0c;那么这不就是在砸罐…

查找算法简记

一、简单查找&#xff08;顺序查找&#xff09; 最基本的查找&#xff0c;相当于遍历&#xff0c;从头到尾一个一个找。 二、二分查找 1、简述 二分查找的输入是一个有序的元素列表。 如果要查找的元素包含在列表中&#xff0c;二分查找返回其位置&#xff1b; 否则返回null。…

开发流程初学者指南——需求分析

目录 从零开始理解需求分析什么是需求分析&#xff1f;需求分析的目标需求分析的基本原则需求分析的各个阶段需求分析的常用方法和工具编写需求文档总结 从零开始理解需求分析 需求分析是软件开发过程中不可或缺的一环&#xff0c;它帮助我们明确用户的需求&#xff0c;确保最…

大模型,多模态大模型面试【LoRA,分类,动静态数据类型,DDPM,ControlNet,IP-Adapter, Stable Diffusion】

大模型&#xff0c;多模态大模型面试【LoRA&#xff0c;分类&#xff0c;动静态数据类型&#xff0c;DDPM&#xff0c;ControlNet&#xff0c;IP-Adapter, Stable Diffusion】 问题一&#xff1a;LoRA是用在节省资源的场景下&#xff0c;那么LoRA具体是节省了内存带宽还是显存呢…

数据结构之链式结构二叉树的实现(进阶版)

本篇文章主要讲解链式二叉树的层序遍历以及判断是否为一棵完全二叉树 二者将会用到之前学过的队列知识&#xff0c;是将队列和二叉树的整合 一、如何将之前已经写好的文件加入当前的编译界面 如图所示&#xff0c;打开我们需要加入文件所在的文件夹&#xff0c;找到我们要加…

StructRAG简介

StructRAG是一种新型的框架&#xff0c;旨在提升大型语言模型&#xff08;LLMs&#xff09;在知识密集型推理任务中的性能。它通过推理时的混合信息结构化机制&#xff0c;根据任务需求以最合适的格式构建和利用结构化知识。 以下是StructRAG的核心组成部分和工作流程&#xff…

Windows Server NTFS磁盘变RAM的处理过程

问题描述 客户服务器的磁盘数据爆满&#xff0c;需要将磁盘进行扩容&#xff0c;因为是虚拟机所以先在虚拟化平台上将原来的磁盘空间改大&#xff0c;再进入系统&#xff0c;在磁盘管理器上将需要扩容的磁盘进行扩展。扩展完后系统报文件系统有问题&#xff0c;扩容的磁盘容量…

LLaMA Factory 核心原理讲解

大家好,我是herosunly。985院校硕士毕业,现担任算法研究员一职,热衷于大模型算法的研究与应用。曾担任百度千帆大模型比赛、BPAA算法大赛评委,编写微软OpenAI考试认证指导手册。曾获得阿里云天池比赛第一名,CCF比赛第二名,科大讯飞比赛第三名。授权多项发明专利。对机器学…

如何让反向代购客户享受丝滑般的下单之旅?

想象一下&#xff0c;一键下单&#xff0c;轻松购物&#xff0c;仿佛穿越时空的魔法&#xff0c;让中国好货瞬间触手可及&#xff01;从made in china的美妆神器到潮流服饰&#xff0c;从尖端数码产品到温馨家居用品&#xff0c;从令人垂涎的美食到贴心的母婴用品&#xff0c;这…