Linux-线程同步

文章目录

  • 前言
  • 一、为什么要线程同步?
  • 二、线程同步
    • pthread_cond_init
    • pthread_cond_destroy
    • pthread_cond_wait、pthread_cond_signal和 pthread_cond_broadcast
  • 三、示例代码


前言

上节课学习了线程互斥,这节课针对线程互斥内容在做进一步的补充和完善,学习线程同步的概念。


提示:以下是本篇文章正文内容,下面案例可供参考

一、为什么要线程同步?

上一章我们所讲的线程互斥有一个问题,虽然我们有互斥锁,但是当我们的临界资源条件不满足时,我们就需要不断重复申请锁和释放锁的过程,做无用功,浪费系统和cpu资源,所以,针对此问题,我们就引入了线程同步来解决。

线程同步其本质就是告诉其他线程什么时候我们的临界资源已经准备就绪,可以开始运行,如果没有准备就绪,那么就阻塞。 这样就能很大程度上节约我们的系统资源。

二、线程同步

pthread_cond_init

man 3 pthread_cond_init
#include <pthread.h>
int pthread_cond_init(pthread_cond_t *restrict cond,
const pthread_condattr_t *restrict attr);
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

该函数与pthread_mutex_init 使用类似,当pthread_cond是全局或静态变量时,可以使用PTHREAD_COND_INITIALIZER来进行初始化。

pthread_cond_destroy

该函数与pthread_mutex_init 使用类似,当pthread_cond是全局或静态变量时,不需要调用此函数进行销毁。

pthread_cond_wait、pthread_cond_signal和 pthread_cond_broadcast

#include <pthread.h>
int pthread_cond_wait(pthread_cond_t *restrict cond,
pthread_mutex_t *restrict mutex)

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

pthread_cond_signal和 pthread_cond_broadcast 这两个函数都是用与告诉需要被同步的线程:条件已经满足,(你)你们可以运行了。
它们俩的区别就是,pthread_cond_signal一次只能一个线程可以运行,而pthread_cond_broadcast则是可以一次若干个线程按次序运行。

pthread_cond_wait函数是用于判断条件是否满足,如果不满足,则阻塞。

三、示例代码

需要注意的是,cond也要配合mutex来进行使用,他们两个是很有关联的。
代码如下(示例):

#include <iostream>
#include <pthread.h>
#include <unistd.h>
#include <cstdio>#define TNUM 5volatile bool quit = false; //防止编译器过度优化typedef void (*Func_t)(std::string, pthread_mutex_t *, pthread_cond_t *);void ThreadFunc1(std::string name, pthread_mutex_t *mutex, pthread_cond_t *cond)
{while (!quit){pthread_mutex_lock(mutex);pthread_cond_wait(cond, mutex);if (!quit/*临界资源条件判断*/)std::cout << name << ": 查看 " << std::endl;pthread_mutex_unlock(mutex);}
}void ThreadFunc2(std::string name, pthread_mutex_t *mutex, pthread_cond_t *cond)
{while (!quit){pthread_mutex_lock(mutex);pthread_cond_wait(cond, mutex);if (!quit/*临界资源条件判断*/)std::cout << name << ": 保存 " << std::endl;pthread_mutex_unlock(mutex);}
}void ThreadFunc3(std::string name, pthread_mutex_t *mutex, pthread_cond_t *cond)
{while (!quit){pthread_mutex_lock(mutex);pthread_cond_wait(cond, mutex);if (!quit/*临界资源条件判断*/)std::cout << name << ": 读取 " << std::endl;pthread_mutex_unlock(mutex);}
}void ThreadFunc4(std::string name, pthread_mutex_t *mutex, pthread_cond_t *cond)
{while (!quit){pthread_mutex_lock(mutex);pthread_cond_wait(cond, mutex);if (!quit/*临界资源条件判断*/)std::cout << name << ": 打印 " << std::endl;pthread_mutex_unlock(mutex);}
}void ThreadFunc5(std::string name, pthread_mutex_t *mutex, pthread_cond_t *cond)
{while (!quit){pthread_mutex_lock(mutex);pthread_cond_wait(cond, mutex);if (!quit/*临界资源条件判断*/)std::cout << name << ": 切换 " << std::endl;pthread_mutex_unlock(mutex);}
}class Data
{
public:Data(std::string name, Func_t func, pthread_mutex_t *mutex, pthread_cond_t *cond): _name(name), _func(func), _mutex(mutex), _cond(cond){}public:std::string _name;Func_t _func;pthread_mutex_t *_mutex;pthread_cond_t *_cond;
};void *Total(void *args)
{Data *cont = (Data *)args;cont->_func(cont->_name, cont->_mutex, cont->_cond);delete cont;return nullptr;
}int main()
{pthread_mutex_t mutex;pthread_cond_t cond;pthread_mutex_init(&mutex, nullptr);pthread_cond_init(&cond, nullptr);pthread_t tids[TNUM];Func_t funcs[TNUM] = {ThreadFunc1, ThreadFunc2, ThreadFunc3, ThreadFunc4, ThreadFunc5};for (int i = 0; i < TNUM; i++){std::string name = "New thread ";name += std::to_string(i + 1);Data *cont = new Data(name, funcs[i], &mutex, &cond);pthread_create(tids + i, nullptr, Total, (void *)cont);}int count = 10;sleep(5);while (count){std::cout << "conut : " << count-- << " -----------" << std::endl;pthread_cond_signal(&cond);// pthread_cond_broadcast(&cond);sleep(1);}quit = true;pthread_cond_broadcast(&cond);for (int i = 0; i < TNUM; i++){pthread_join(tids[1], nullptr);std::cout << "New thread " << i + 1 << " has quit." << std::endl;}pthread_mutex_destroy(&mutex);pthread_cond_destroy(&cond);return 0;
}

在这里插入图片描述


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

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

相关文章

【Python 48小时速成 3】输入与输出

在 Python 中&#xff0c;输入和输出通常通过内置函数来实现。主要的输入函数是 input()&#xff0c;用于从用户获取输入&#xff0c;而输出函数则是 print()&#xff0c;用于将结果打印到控制台。以下是简单的代码示例演示了输入和输出&#xff1a; # 输入示例 name input(&…

[C语言]一维数组二维数组的大小

对于一维数组我们知道取地址是取首元素的地址&#xff0c;二维数组呢&#xff0c;地址是取第一行的地址&#xff0c;sizeof(数组名)这里计算的就是整个数组的大小&#xff0c;&数组名 表示整个数组&#xff0c;取出的是整个数组的地址&#xff0c;显示的是数组的首元素 记…

网络工程师练习题2

网络工程师 将专用IP地址转换为公用IP地址的技术是&#xff08;&#xff09;。 A.ARPB.DHCPC.UTMD.NAT 【答案】D 【解析】概念题&#xff0c;NAT技术将源地址从内部专用地址转换成可以在外部Internet上路由的全局IP地址。 R1、R2是一个自治系统中采用RIP路由协议的两个相…

Java基础知识总结(8)

StringBuilder类(是线程不安全的) StringBuffer 和 StringBuilder二者及其相似&#xff0c;下面是构造方法&#xff1a; StringBuilder StringBuilder()创建空对象&#xff0c;空的字符序列 StringBuilder StringBuilder(StringBuilder builder)传入对象创造字符序列 Strin…

【计算机网络篇】物理层(4)信道的极限容量,信道复用技术

文章目录 &#x1f354;信道的极限容量&#x1f6f8;造成信号失真的主要因素⭐码元的传输速率 &#x1f6f8;奈氏准则&#x1f6f8;香农公式&#x1f388;练习 &#x1f5d2;️小结 &#x1f354;信道复用技术⭐常见的信道复用技术&#x1f388;频分复用FDM&#x1f388;时分复…

时序分解 | Matlab实现GWO-CEEMDAN基于灰狼算法优化CEEMDAN时间序列信号分解

时序分解 | Matlab实现GWO-CEEMDAN基于灰狼算法优化CEEMDAN时间序列信号分解 目录 时序分解 | Matlab实现GWO-CEEMDAN基于灰狼算法优化CEEMDAN时间序列信号分解效果一览基本介绍程序设计参考资料 效果一览 基本介绍 1.CEEMDAN方法的分解效果取决于白噪声幅值权重(Nstd)和噪声添…

【刷题】滑动窗口入门

送给大家一句话&#xff1a; 那脑袋里的智慧&#xff0c;就像打火石里的火花一样&#xff0c;不去打它是不肯出来的。——莎士比亚 滑动窗口入门 认识滑动窗口Leetcode 209. 长度最小的子数组题目描述算法思路 Leetcode 3. 无重复字符的最长子串题目描述算法思路 Leetcode 1004…

部署应用到K8s集群(未完)

&#xff08;等熟悉一番再来写&#xff0c;因为按小时结算的。。。&#xff09; 1 、 kubectl run 启动 nginx 应用 kubectl run nginx --imagenginx:latest 2、将本地机器的80端口转发到集群中名为nginx的Pod的80端口 kubectl port-forward --address 0.0.0.0 pod/nginx 80:8…

AHI对MySQL性能的影响

MySQL中出现很多latch锁&#xff0c;而这个很大程度上和MySQL自适应hash索引有关。 AHI概述 MySQL InnoDB存储引擎的自适应哈希&#xff08;Adaptive Hash Index&#xff0c;下简称AHI&#xff09;功能 若用户的访问模式基本都是类似KV操作的点查询&#xff08;point select&…

es bulk批量操作简单实例

&#xff08;1&#xff09;定义 bulk允许在单个步骤中进行多次create、index、update或delete请求。 bulk与其他的请求体格式稍有不同&#xff0c;如下所示&#xff1a; { action: { metadata }}\n { request body }\n { action: { metadata }}\n { request body …

FPGA高端项目:FPGA基于GS2971+GS2972架构的SDI视频收发+HLS图像缩放+多路视频拼接,提供4套工程源码和技术支持

目录 1、前言免责声明 2、相关方案推荐本博主所有FPGA工程项目-->汇总目录本博已有的 SDI 编解码方案本方案的SDI接收发送本方案的SDI接收图像缩放应用本方案的SDI接收纯verilog图像缩放纯verilog多路视频拼接应用本方案的SDI接收OSD动态字符叠加输出应用本方案的SDI接收HLS…

社会责任管理体系审核员

为满足国家越来越多的各种类型、各种规模的企业组织能按照 GB/T 39604-2020《社会责任管理体系要求及使用指南》国家标准建立相应制度&#xff0c;助力组织实现其社会责任管理体系的预期结果&#xff0c;以及满足各类组织对社会责任管理体系实践的需要&#xff0c;了解社会责任…

rr 为什么会出现幻读?

首先要知道mvcc的两个概念&#xff0c; 1. undolog 可以理解为就是一个数据快照&#xff0c;里面包含数据&#xff0c;当前事务ID&#xff08;相当于版本号&#xff09;和上一个快照的指针。类似链表。 2. readview 可以理解为事务 读快照&#xff0c; 记录当前事务ID&#xff…

工作需求iview 组件的使用

加油&#xff0c;新时代打工人&#xff01; 源码下载地址 <template><div mouseenter"mousein true" mouseleave"mousein false"><el-input type"text" clearable autocomplete"off" v-model"searchDoc.code&q…

【CSS】html滚动条相关

1.滚动条样式 ::-webkit-scrollbar {width: 10px;height: 10px;z-index: 101; } ::-webkit-scrollbar-thumb {border-radius: 5px;background: #cecece; } ::-webkit-scrollbar-track {// background: #f5f5f5be;background: rgba(33, 85, 163, 0); } ::-webkit-scrollbar-but…

Rust 基于 await、async 的异步编程和纤程、协程的实现

一、Rust 的异步编程 Rust 通过 await、async 实现了其他语言中纤程、协程的机制。下面是一个使用async和await的Rust示例代码。这个示例展示了如何异步地读取文件内容。 首先&#xff0c;确保你的Cargo.toml文件包含了tokio库的依赖&#xff0c;如下&#xff1a; [dependen…

python汽车租赁系统的设计与实现flask-django-php-nodejs

困扰公司的许多问题当中,汽车租赁管理一定是公司不敢忽视的一块。但是管理好汽车租赁又面临很多麻烦需要解决,例如有几个方面:第一,公司往往汽车数量都比较多,如何保证能够管理到每一汽车;第二,如何在工作琐碎,记录繁多的情况下将汽车租赁的当前情况反应给公司领导相关部门决策…

Python之Web开发中级教程----ubuntu中下载安装Postman

Python之Web开发中级教程----ubuntu中下载安装Postman PostMan 是一款功能强大的网页调试与发送网页 HTTP 请求的 Chrome 插件&#xff0c;可以直接去对我们写出来的路由和视图函数进行调试&#xff0c;作为后端程序员是必须要知道的一个工具。 查看ubuntu系统中是否已经安装了…

零基础学华为ip认证难吗?华为认证费用多少?

零基础学华为ip认证难吗&#xff1f; 首先&#xff0c;零基础的学习者可以通过系统的学习&#xff0c;逐步掌握网络基础知识和技能。可以通过阅读教材、参加培训课程、进行实践操作等方式&#xff0c;不断提升自己的知识和技能水平。同时&#xff0c;学习者还可以利用华为提供的…

常用小知识点总结

1. pc可以跑通&#xff0c;但是安卓编译死循环&#xff0c;可能是函数声明了返回类型&#xff0c;但是没有真正返回 2. ubuntu下根据关键词杀死所有相关进程。ps -ef | grep code | grep -v grep | cut -c 10-16 | xargs kill -s 9 top和ps基本作用都是显示系统进程状况&…