线程条件控制实现线程的同步

与条件变量相关API
        条件变量是线程另一可用的同步机制。条件变量给多个线程提供了一个会合的场所。条件变量与互斥量一起使用时,允许线程以无竞争的方式等待特定的条件发生。

        条件本身是由互斥量保护的。线程在改变条件状态前必须首先锁住互斥量,其他线程在获得互斥量之前不会察觉到这种改变,因为必须锁定互斥量以后才能计算条件。

        条件变量使用之前必须首先初始化,pthread_cond_t数据类型代表的条件变量可以用两种方式进行初始化,可以把常量        PTHREAD_COND_INITIALIZER赋给静态分配的条件变量,但是如果条件变量是动态分配的,可以使用pthread_cond_destroy函数对条件变量进行去除初始化(deinitialize)。
1. 创建及销毁条件变量

#include <pthread.h>
int pthread_cond_init(pthread_cond_t *restrict cond, const pthread_condattr_t *restrict attr);
int pthread_cond_destroy(pthread_cond_t*restrict cond);
// 返回:若成功返回0,否则返回错误编号

除非需要创建一个非默认属性的条件变量,否则pthread_cont_init函数的attr参数可以设置为NULL。cond参数是条件也要进行定义和初始化
2. 等待

#include <pthread.h>
int pthread_cond_wait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex);//这个是立即返回
int pthread_cond_timedwait(pthread_cond_t *restrict cond, pthread_mutex_t *restrict mutex, cond struct timespec *restrict timeout);//这个是等待一段时间后返回
// 返回:若成功返回0,否则返回错误编号

        pthread_cond_wait等待条件变为真。如果在给定的时间内条件不能满足,那么会生成一个代表一个出错码的返回变量。传递给pthread_cond_wait的互斥量对条件进行保护,调用者把锁住的互斥量传给函数。函数把调用线程放到等待条件的线程列表上,然后对互斥量解锁,这两个操作都是原子操作。这样就关闭了条件检查和线程进入休眠状态等待条件改变这两个操作之间的时间通道,这样线程就不会错过条件的任何变化。pthread_cond_wait返回时,互斥量再次被锁住。

        pthread_cond_timedwait函数的工作方式与pthread_cond_wait函数类似,只是多了一个timeout。timeout指定了等待的时间,它是通过timespec结构指定。
3. 触发

#include <pthread.h>
int pthread_cond_signal(pthread_cond_t*restrict    cond);
int pthread_cond_broadcast(pthread_cond_t *restrict cond);
// 返回:若成功返回0,否则返回错误编号

这两个函数可以用于通知线程条件已经满足。pthread_cond_signal函数将唤醒等待该条件的某个线程,而pthread_cond_broadcast函数将唤醒等待该条件的所有进程。

注意一定要在改变条件状态以后再给线程发信号。
  
代码示例

#include<stdio.h>
#include<pthread.h>
#include <stdlib.h>
//int pthread_create(pthread_t *restrict tidp, const pthread_attr_t *restrict attr, void *(*start_rtn)(void *), void *restrict arg);int g_data=0;//pthread_mutex_t mutex;
pthread_cond_t cond;void*func1(void *arg)
{static cnt=0;printf("t1 :%ld thread is created\n",(unsigned long)pthread_self());printf("t1:param is %d\n",*((int*)arg));while(1){pthread_cond_wait(&cond,&mutex);printf("t1 over==============================\n");printf("t1 :%d\n",g_data);g_data=0;sleep(1);if(cnt++==10){exit(1);}}}void*func2(void *arg)
{printf("t2 :%ld thread is created\n",(unsigned long)pthread_self());
printf("t2:param is %d\n",*((int*)arg));while(1){printf("t2 printf is %d\n",g_data);pthread_mutex_lock(&mutex);g_data++;if(g_data==3){pthread_cond_signal(&cond);}pthread_mutex_unlock(&mutex);sleep(1);}pthread_mutex_unlock(&mutex);
}int main()
{int ret;int param=100;pthread_t t1;pthread_t t2;pthread_mutex_init(&mutex,NULL);pthread_cond_init(&cond,NULL);ret=pthread_create(&t1,NULL,func1,(void*)&param);if(ret==0){//      printf("main:create t1 success\n");}ret=pthread_create(&t2,NULL,func2,(void*)&param);if(ret==0){
//      printf("main:create t2 success\n");}
//      printf("main : %ld \n",(unsigned long)pthread_self());pthread_join(t1,NULL);pthread_join(t2,NULL);pthread_mutex_destroy(&mutex);pthread_cond_destroy(&cond);return 0;
}
//其中func1中的cnt是测试用的
以下代码可以用试:
CLC@Embed_Learn:~/xiancheng$ gcc demo8.c -lpthread -odemo8
CLC@Embed_Learn:~/xiancheng$ vi text1.c
CLC@Embed_Learn:~/xiancheng$ ./a.out 10 >>test.ret.txt &(其中>>表示将运行的结果追加到test.ret.txt中     &表示在后台运行)
[1] 21313(这是进程的ID号)

初始化

pthread_mutex_t mutex=PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond=PTHREAD_COND_INITIALIZER;
//静态初始化
pthread_mutex_init(&mutex,NULL);
pthread_cond_init(&cond,NULL);
//动态初始化

参考博文:https://www.cnblogs.com/xiehongfeng100/p/4620852.html

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

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

相关文章

自定义能够for each的类,C#,Java,C++,C++/cli的实现方法

自定义类能够被for each&#xff0c;应该算是个老生常谈的话题了&#xff0c;相关的资料都很多&#xff0c;不过这里整理总结主流语言的不同实现方式&#xff0c;并比较部分细节上的差异。 第一种语言&#xff0c;也是实现起来最简单的Java语言。在Java里&#xff0c;要被for e…

SQL Server 2008 R2:快速清除日志文件的方法

本例&#xff0c;快速清理“students”数据库的日志&#xff0c;清理后日志文件不足1M。USE [master] GO ALTER DATABASE students SET RECOVERY SIMPLE WITH NO_WAIT GO ALTER DATABASE students SET RECOVERY SIMPLE GO USE students GO--此处需要注意&#xff…

linux网络编程之字节序

进程间通信 特点&#xff1a;依赖于内核&#xff0c;造成缺陷——无法实现多机通信。 网络编程 地址&#xff1a;由IP地址和端口号构成&#xff0c;端口号用来判断客户端接入哪个服务器。 数据的交流&#xff1a;涉及到协议&#xff08;http&#xff0c;tcp&#xff0c;udp&…

Oracle查看表空间和表空间中的对象

select * from user_tables;--查询所有用户表 select username,default_tablespace from user_users;--查询当前表空间select tablespace_name from dba_tablespaces;--查询所有表空间select tablespace_name, sum(bytes)/1024/1024 from dba_data_files group by tablespace_n…

C#中DateTime.Ticks属性及Unix时间戳转换

DateTime.Ticks&#xff1a;表示0001 年 1 月 1 日午夜 12:00:00 以来所经历的 100 纳秒数&#xff0c;即Ticks的属性为100纳秒&#xff08;1Ticks 0.0001毫秒&#xff09;。Unix时间戳&#xff1a;是从1970年1月1日&#xff08;UTC/GMT的午夜&#xff09;开始所经过的秒数&am…

WebBrowser控件的常用方法、属性和事件

1. 属性属性说明Application如果该对象有效&#xff0c;则返回掌管WebBrowser控件的应用程序实现的自动化对象(IDispatch)。如果在宿主对象中自动化对象无效&#xff0c;这个程序将返回WebBrowser 控件的自动化对象Parent返回WebBrowser控件的父自动化对象&#xff0c;通常是一…

二维码高亮

// 二维码高亮。http://blog.sina.com.cn/s/blog_a843a8850102uy6w.html 转载于:https://www.cnblogs.com/muyushifang07/p/5114667.html

socket 网络 编程

网络编程场景 自己是客户端站在5栋楼前&#xff0c;自己要找到5栋楼中的一座并进入某一间房间&#xff0c;这时第二座楼上有人在用汉语&#xff08;tcp/udp&#xff09;说话,我的ip地址&#xff08;楼号&#xff09;是…&#xff0c;我的端口号&#xff08;房间号&#xff09;是…

7个免费的Linux FTP客户端工具

在Dropbox、YouSendIt、idrive以及许多这样云存储和共享工具的帮助下&#xff0c;我们在互联网上发送和共享大型文件变得容易起来。所有这些网站都可以帮助你在互联网上传送文件&#xff0c;但如果你要分享庞大的数据&#xff0c;这依然是很复杂的事情。所以&#xff0c;你需要…

树莓派的几种登录方式及树莓派的网络配置

&#xff08;1&#xff09;HDMI 视频线 连接到显示器 &#xff08;2&#xff09;串口 设备破解&#xff1a; 默认情况下,树莓派的串口和蓝牙连接&#xff0c;把串口用来数据通信。 修改系统配置&#xff0c;启用串口登录树莓派 1.打开SD卡根目录的"config.txt"文件…

C语言之常量与变量

1.常量 1.1整型常量:短整型(short int),整型(int),长整型(long int).短整型和长整型都可省虑后面的int,三者唯一的区别就是内存大小的区别,从小到大依次为short < int < long. int a;short int b;long int c;  printf("%d,%d",a,b);  printf("%ld&quo…

【收集】11款Linux数据恢复工具

如果你使用的是Linux操作系统&#xff0c;那么你一定想知道一旦硬盘崩溃的话又该如何保存和恢复数据。其实&#xff0c;现在有很多Linux数据恢复工具可以让我们摆脱数据安全的困扰。小编已经为各位准备好了一些最好的Linux数据恢复工具&#xff0c;欢迎大家品鉴。KnoppixKnoppi…

VIM更新

1、可以用以下指令 sudo apt-get install vim2、默认的是国外的源&#xff0c;apt-get 安装失败的时候&#xff0c;我们更换成国内的源。 &#xff08;1&#xff09; 编辑sources.list 打开终端输入 sudo nano /etc/apt/sources.list用#注释或直接删除原有的内容&#xff0c…

svn 常用操作命令

检出svn co svn://xxxxx/svn/ios --username jm --password 123 通常情况下&#xff0c;命令svn add *会忽略所有已经在版本控制之下的目录&#xff0c;有时候&#xff0c;你会希望添加所有工作拷贝的未版本化文件&#xff0c;包括那些隐藏在深处的文件&#xff0c;可以使用svn…

8款适合Linux用户使用的数据库管理工具

从内容管理系统到简单的表格&#xff0c;数据库是每一个开发项目的一部分。这就是为什么开发者们如此强调使用正确类型的数据库工具。下面这些可能对您有所帮助&#xff01;1. AutotablaAutotabla是一个你的程序的SQL数据表的CGI管理界面。只需要提供你数据库架构的XML描述&…

linux库引入之分文件编程

分文件编程好处 将main函数和其他功能性函数放在不同的文件中&#xff0c;分模块的编程思想&#xff0c;分工明确&#xff0c;查找错误比较容易&#xff0c;责任可以划分清楚&#xff0c;程序也方便调试&#xff0c;并且主函数比较简洁。 将文件从同一目录下的另一个文件夹拷贝…

为什么Chrome浏览器特爱吃内存

微软用惯用的手法——改名——给 IE 被黑的一生画上了句号。还好&#xff0c;它在技术段子圈里早就有了接班人&#xff1a;Chrome。Chrome 很好很强大&#xff0c;速度极快、功能很多。但同时它也是你的电脑内存不足或者耗电太快的罪魁祸首。没办法&#xff0c;Chrome 太爱吃内…

nyoj--120--校园网络(scc+缩点)

校园网络 时间限制&#xff1a;3000 ms | 内存限制&#xff1a;65535 KB难度&#xff1a;5描述南阳理工学院共有M个系&#xff0c;分别编号1~M,其中各个系之间达成有一定的协议&#xff0c;如果某系有新软件可用时&#xff0c;该系将允许一些其它的系复制并使用该软件。但该允…

SQL的四种连接用法整理

1、内联接&#xff08;典型的联接运算&#xff0c;使用像 或 <> 之类的比较运算符&#xff09;。包括相等联接和自然联接。 内联接使用比较运算符根据每个表共有的列的值匹配两个表中的行。例如&#xff0c;检索 students和courses表中学生标识号相同的所有行。 …

简述 OAuth 2.0 的运作流程

本文将以用户使用 github 登录网站留言为例&#xff0c;简述 OAuth 2.0 的运作流程。 假如我有一个网站&#xff0c;你是我网站上的访客&#xff0c;看了文章想留言表示「朕已阅」&#xff0c;留言时发现有这个网站的帐号才能够留言&#xff0c;此时给了你两个选择&#xff1a;…