调用另一个cpp的变量_再谈条件变量—从入门到出家

再谈条件变量—从入门到出家


C语言--条件变量

条件变量是在线程中以睡眠的方式等待某一条件的发生;

条件变量是利用线程间共享的全局变量进行同步的一种机制:

  • 一个线程等待"条件变量的条件成立"挂起
  • 另一个线程使"条件成立"

条件变量的使用总是和一个互斥锁结合在一起;

**作用:**使用条件变量可以以原子方式阻塞线程,直到某个特定条件为真为止


我们一般使用的函数是:

#include <semaphore.h>
int pthread_cond_init(pthread_cond_t *cond, pthread_condattr_t *cond_attr) ;
int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex);
int pthread_cond_signal(pthread_cond_t *cond);
int pthread_cond_broadcast(pthread_cond_t *cond);
int pthread_cond_destroy(pthread_cond_t *cond);
案例一

代码:

#include <stdio.h>
#include <semaphore.h>
#include <pthread.h>pthread_t t1;
pthread_t t2;pthread_mutex_t mutex;
pthread_cond_t cond;int i=0;void* Process1(void* arg)
{while(1){pthread_mutex_lock(&mutex);i++;if(i%5 == 0){pthread_cond_signal(&cond);}else{printf("this is Process1n");}pthread_mutex_unlock(&mutex);sleep(2);}
}void* Process2(void* arg)
{while(1){pthread_mutex_lock(&mutex);pthread_cond_wait(&cond,&mutex);printf("this is Process2,i=%dn",i);pthread_mutex_unlock(&mutex);sleep(2);}
}int main()
{pthread_cond_init(&cond,NULL);pthread_mutex_init(&mutex,NULL);pthread_create(&t1,NULL,Process1,NULL);pthread_create(&t2,NULL,Process2,NULL);pthread_join(t1,NULL);pthread_join(t2,NULL);return 0;
}

结果:

root@iZuf67on1pthsuih96udyfZ:~/C++/C++_test/Progress/cond# ./test1 
this is Process1
this is Process1
this is Process1
this is Process1
this is Process2,i=5
this is Process1
this is Process1
this is Process1
this is Process1
this is Process2,i=10
this is Process1
this is Process1
^C

通过条件变量来控制线程的输出;


上述是在C语言中使用条件变量对线程进行一个控制,在C++中,在标准库中也提供了同样的机制,使用起来会比C语言的更加方便,但是原理还是一样的;

C++ 条件变量

C++标准库在< condition_variable >中

原则与C语言中类似

  • 包含< mutex >和< condition_variable >,声明一个mutex和一个condition_variable变量
  • 通知“条件已满足”的线程必须调用notify_one()或notify_all(),条件满足时唤醒处于等待中的一个条件变量;
  • 等待"条件被满足"的线程必须调用wait(),可以让线程在条件未被满足时陷入休眠状态,当接收到通知时被唤醒去处理相应的任务;
C++ 使用案例
#include <iostream>
#include <thread>
#include <condition_variable>
#include <mutex>
#include <unistd.h>using namespace std;//全局条件变量
condition_variable cond;
mutex _mutex;
int count = 0;void fun1()
{while(1){count++;unique_lock<mutex>lock(_mutex);if(count%5 == 0){cond.notify_one();}else{cout<<"this is fun1,count="<<count<<endl;}lock.unlock();sleep(1);}
}void fun2()
{while(1){unique_lock<mutex>lock(_mutex);cond.wait(lock);cout<<"this is fun2,count="<<count<<endl;lock.unlock();sleep(2);}
}int main()
{thread t1(fun1);thread t2(fun2);t1.join();t2.join();return 0;
}

结果:

root@iZuf67on1pthsuih96udyfZ:~/C++/C++_test/Progress/cond# g++ -std=c++11 test2.cpp -o test2 -lpthread
root@iZuf67on1pthsuih96udyfZ:~/C++/C++_test/Progress/cond# ./test2
this is fun1,count=1
this is fun1,count=2
this is fun1,count=3
this is fun1,count=4
this is fun2,count=5
this is fun1,count=6
this is fun1,count=7
this is fun1,count=8
^C

到这里,基本回顾了C和C++中条件变量的用法,但是在实际应用中。又有设么用呢?

可能工作年限多的人,接触到的比较多,但是对于很多小白来说,或者刚毕业、刚参加工作的人来说,这点接触的就不是很多了,。这里来举一个例子说一下:

假如在某个项目中,需要用到的是多个线程,最简单的就是,用队列的时候,我们一边写一边读,总是要加锁的,但是,我们的线程就必须一直空转对队列进行检测是否有数据,但是这样往往会造成CPU使用率比较高,资源的浪费,这种情况下,我们就可以是使用条件变量,控制线程的循环,降低资源使用率;当然,也有很多场景值得去探索,也有很多技术可以解决这这个问题,希望大家一起探索前进;

问题思考

上面介绍了C和C++中的使用,但是其实还是有些疑问的

疑问:为什么pthread_cond_wait前加了锁,但是pthread_cond_signal还可以加锁?

首先看下我从网上找的一张图:

786161db8180ec4de99eaae5c8f361fe.png

从这个图片中,我们发现了一个现象,pthread_cond_wait函数内存进行对锁的解锁,并且阻塞休眠操作,阻塞完成后,再次进行了加锁操作;也就是在pthread_cond_wait阻塞期间,pthread_cond_signal可以进行加锁和解锁操作,这里是不冲突的;

往期精彩文章汇总
  • muduo源码剖析学习总结
  • 掌握这个技能,你可以畅游github
  • C++ 简单对象池实现
  • 内存池设计与实现
  • 恭喜你!发现宝藏一份--技术文章汇总

想了解学习更多C++后台服务器方面的知识,请关注: 微信公众号:====CPP后台服务器开发====


冰冻三尺,非一日之寒,水滴石穿,非一日之功,愿我们一起加油努力~

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

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

相关文章

python 测试端口连通_Python语言 实现端口连通性检测

本文主要向大家介绍了Python语言 实现端口连通性检测&#xff0c;通过具体的内容向大家展示&#xff0c;希望对大家学习Python语言有所帮助。# -*- coding: utf-8 -*-#!/bin/env python#AUTHOR:karl#DATE:2018-1-19#VERSION:V1.0######################import timeimport osimp…

table每行自动触发ajax,table.ajax.reload()成功后未触发:function()

简介我正在使用json&#xff0c;ajax和php进行datatables.net jquery服务器端处理。我可以单击行按钮&#xff0c;然后从数据库中删除该行。但是&#xff0c;该页面永远不会使用ajax.reload();刷新页面。问题此代码&#xff1a;console.log("success function data reache…

不同page页面选择不同页面模板的方法

仿制一个企业站的时候发现该站用了很多page页面&#xff0c;而且个别页面的样式不相同&#xff0c;同时区别于post文章页面&#xff0c;其实不同之处就在于每个页面的xhtmlcss的不同&#xff0c;关键是page模板选择的问题&#xff0c;恒宁总结了以下两种方法。 第一种&#xff…

jquer each 遍历的结果不显示 null_SpringBoot系列(三十一)- Thymeleaf如何用th:each 做条件遍历

步骤1:基于前面的知识点步骤2:先运行&#xff0c;看到效果&#xff0c;再学习步骤3:模仿和排错步骤4:TestController步骤5:普通遍历步骤6:带状态的遍历步骤7:结合 select步骤8:结合 单选框步骤9:完整的 test.html步骤10:重启测试步骤 1 : 基于前面的知识点本知识点是建立在上一…

python 属性描述符_Python属性描述符(二)

Python存取属性的方式特别不对等&#xff0c;通过实例读取属性时&#xff0c;通常返回的是实例中定义的属性&#xff0c;但如果实例未曾定义过该属性&#xff0c;就会获取类属性&#xff0c;而为实例的属性赋值时&#xff0c;通常会在实例中创建属性&#xff0c;而不会影响到类…

python3.6sysos_求大佬,这是什么情况啊

该楼层疑似违规已被系统折叠 隐藏此楼查看此楼 Traceback (most recent call last): File "manager.py", line 13, in sys.exit(main()) File "manager.py", line 8, in main manager.run() File "/root/imooc/lib/python3.5/site-packages/flask_sc…

6个座位办公室最佳位置_四人办公室座次的首选最佳座位在哪儿

四人办公室虽然不再拥挤&#xff0c;但座次依然有好坏之分&#xff0c;首选最佳的座位应靠着窗户并不与门相对。选择一个好的座位&#xff0c;不仅有助于我们工作效率和工作质量的提高&#xff0c;还能帮助我们的事业运和财运得到提升。在大多数人较多的办公室里&#xff0c;并…

.Net学习笔记----2015-06-30(超市收银系统01-仓库类)

GUID&#xff1a; 产生一个不会重复的ID static void Main(string[] args){//产生一个不会重复的编号Console.WriteLine(Guid.NewGuid().ToString());Console.WriteLine(Guid.NewGuid().ToString());Console.WriteLine(Guid.NewGuid().ToString());Console.WriteLine(Guid.NewG…

python xml etree_python xml.etree解析xml

config.xml <?xml version"1.0" encoding"UTF-8"?>linux 30windows 201 &#xff0c;解析出xml文件的根元素 from xml.etree import ElementTree as ET treeET.parse(config.xml) roottree.getroot() 或者 &#xff08;从字符串中解析&#xff09;…

http协议报文体_HTTP协议扫盲(七)请求报文之 GET、POST-FORM 和 POST-FILE

ORACLE临时表空间总结临时表空间概念 临时表空间用来管理数据库排序操作以及用于存储临时表.中间排序结果等临时对象,当ORACLE里需要用到SORT的时候,并且当PGA中sort_area_size大小不够时,将会把数据放入 ...web自学网站coursera 网站很多新的技术,都是大牛和牛大学的,和外国新…

Winform开发之ADO.NET对象Connection、Command、DataReader、DataAdapter、DataSet和DataTable简介...

ADO.NET技术主要包括Connection、Command、DataReader、DataAdapter、DataSet和DataTable等6个对象&#xff0c;下面对这6个对象进行简单的介绍&#xff1a;&#xff08;1&#xff09;Connection对象的主要功能是与数据库进行连接&#xff08;事物处理也使用此对象&#xff09;…

python电子英汉词典显示_python网页抓取之英汉字典

linux的字典本人实在用起来不舒服&#xff08;stardict挺不错的&#xff0c;但是界面好看些&#xff0c;功能简单易用就好了&#xff09; &#xff0c;在线翻译又得打开庞大的浏览器....就打算自己写个&#xff0c;但是时间有限&#xff0c;为了简单&#xff0c; 还是用python抓…

清空缓存的命令_超详细的mysql数据库查询缓存原理解析、涉及命令、流程分析等...

概述mysql查询缓存在数据库优化可以起到很大的作用&#xff0c;今天主要针对这一块做一个总结&#xff0c;下面一起来看看吧~一、缓存条件&#xff0c;原理MySQL Query Cache是用来缓存我们所执行的SELECT语句以及该语句的结果集&#xff0c;MySql在实现Query Cache的具体技术细…

python与tensorflow的关系_python – 在TensorFlow,Session.run()和Tensor.eval()之间有什么区别?...

如果你有Tensor t&#xff0c;调用 t.eval()相当于调用tf.get_default_session()。run(t)。 您可以将会话设置为默认值&#xff0c;如下所示&#xff1a; t tf.constant(42.0) sess tf.Session() with sess.as_default(): # or with sess: to close on exit assert sess is t…

和lua的效率对比测试_Unity游戏开发Lua更新运行时代码!

最近沉迷lua脚本热更&#xff0c;想说这个可以提高多少菜鸡的调试效率&#xff0c;找了网上好多文章&#xff0c;但是都不行&#xff0c;尝试了很久&#xff0c;并且自己测试和学习&#xff0c;写了一遍&#xff0c;勉强能热更了。下面记录一下热更Lua的过程。一、用来卸载表格…

nodejs cluster ip hash_redis集群架构了解一下?一致性hash了解吗?

在前几年&#xff0c;redis 如果要搞几个节点&#xff0c;每个节点存储一部分的数据&#xff0c;得借助一些中间件来实现&#xff0c;比如说有 codis&#xff0c;或者 twemproxy&#xff0c;都有。有一些 redis 中间件&#xff0c;你读写 redis 中间件&#xff0c;redis 中间件…

硬盘主分区和拓展分区

主分区,也称为主磁盘分区,和扩展分区、逻辑分区一样,是一种分区类型。主分区中不能再划分其他类型的分区,因此每个主分区都相当于一个逻辑磁盘(在这一点上主分区和逻辑分区很相似,但主分区是直接在硬盘上划分的,逻辑分区则必须建立于扩展分区中)。 1. 一个硬盘可以有1到3个主分…

python如何比较大小_python列表如何比较大小

python列表如何比较大小 发布时间:2020-09-22 13:58:58 来源:亿速云 阅读:59 作者:小新 这篇文章给大家分享的是有关python列表如何比较大小的内容。小编觉得挺实用的,因此分享给大家做个参考。一起跟随小编过来看看吧。 Python中可以使用cmp()函数比较两个列表的大小。 c…

python 连接oracle_常用的Python库,给大家分享一下!

Tkinter———— Python默认的图形界面接口。Tkinter是一个和Tk接口的Python模块&#xff0c;Tkinter库提供了对Tk API的接口&#xff0c;它属于Tcl/Tk的GUI工具组。Tcl/Tk是由John Ousterhout发展的书写和图形设备。Tcl(工具命令语言)是个宏语言&#xff0c;用于简化shell下复…

js 获取某年的某天是第几周

/**2 * 判断年份是否为润年3 *4 * param {Number} year5 */6 function isLeapYear(year) {7 return (year % 400 0) || (year % 4 0 && year % 100 ! 0);8 }9 /**10 * 获取某一年份的某一月份的天数11 *12 * param {Number} year13 * param {Number} month14 *…