linux-线程条件变量(cond)

news2024/11/26 14:24:00

概述

        与互斥锁不同,条件变量是用来等待而不是用来上锁的。条件变量用来自动阻塞一个线程,直到某特殊情况发生为止。通常条件变量和互斥锁同时使用
        条件变量使我们可以睡眠等待某种条件出现。条件变量是利用线程间共享的全局变量进行同步的一种机制,主要包括两个动作:
        1.一个线程等待"条件变量的条件成立"而挂起;
        2.另一个线程使 “条件成立”(给出条件成立信号)
        想象一种情况,我创建一个线程去执行下雨收衣服的工作,但是大多数时候天气都是晴天,只有下雨天这个线程才会去工作,那么我就需要这个线程睡眠,不要浪费CPU 资源,等下雨时我再叫醒它起来工作就行了,线程条件变量就是扮演这样一个角色。
        条件的检测是在互斥锁的保护下进行的。线程在改变条件状态之前必须首先锁住互斥量。如果一个条件为假,一个线程自动阻塞,并释放等待状态改变的互斥锁。如果另一个线程改变了条件,它发信号给关联的条件变量,唤醒一个或多个等待它的线程,重新获得互斥锁,重新评价条件。如果两进程共享可读写的内存,条件变量 可以被用来实现这两进程间的线程同步。
        在 linux 的 pthread 中使用条件变量的类型为:pthread_cond_t 表示一个条件变量
typedef union
{
        struct __pthread_mutex_s __data ;
        char __size [ __SIZEOF_PTHREAD_MUTEX_T ];
        long int __align ;
} pthread_mutex_t ;
对线程条件变量的操作可以有
1.初始化条件变量
2.销毁条件变量
3.等待条件变量(线程睡眠)
4.唤醒等待条件变量的线程

初始化条件变量

动态初始化(pthread_cond_init)

头文件:
#include <pthread.h>
函数原型:
int pthread_cond_init(pthread_cond_t *restrict cond,const pthread_condattr_t *restrict attr);
作用:
        初始化线程条件变量 cond
参数含义:
        cond:线程条件变量
        attr:线程条件变量的属性,为空表示默认属性
返回值:
        成功返回 0,
        失败返回错误号

静态初始化

在 linux 中使用静态存储区中的 PTHREAD_COND_INITIALIZER 就可以对条件变量完成静
态初始化
/* Conditional variable handling. */
#define PTHREAD_COND_INITIALIZER { { { 0 }, { 0 }, { 0 , 0 }, { 0 , 0 }, 0 , 0 , { 0 , 0 } } }
如下:
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

销毁条件变量(pthread_cond_destroy)

头文件:
#include <pthread.h>
函数原型:
int pthread_cond_destroy(pthread_cond_t *cond);
作用:
        销毁线程条件变量 cond
参数含义:
         cond: 线程条件变量
返回值:
        成功返回 0,
        失败返回错误号

等待一个条件变量(线程睡眠)

阻塞等待(pthread_cond_wait)

头文件:
#include <pthread.h>
函数原型:
int pthread_cond_wait(pthread_cond_t *restrict cond,pthread_mutex_t *restrict mutex);
作用:
        阻塞等待条件变量 cond 的值,线程进入睡眠状态并解锁,直到被条件变量唤醒
参数含义:
        cond:线程条件变量
        mutex:互斥锁
返回值:
        成功返回 0,
        失败返回错误号
备注:
        1.因为条件变量本身是一个“共享资源”,为了避免竞争,需要一个线程互斥锁来保护
        2.在 pthread_cond_wait/pthread_cond_timewait 需要把锁住的互斥锁传入函数,在函数内部实现的时候,线程让出 CPU(休眠)前,释放传入的互斥锁,然后再休眠
        3.休眠到直到条件发生(被唤醒),被唤醒的时候,再次重新锁住传入的锁(不会带锁休眠),也就是说线程在睡眠的时候会解锁,在被唤醒时会去获取锁

限时等待(pthread_cond_timedwait)

头文件:
#include <pthread.h>

函数原型:

int pthread_cond_timedwait(pthread_cond_t *restrict cond,pthread_mutex_t *restrict mutex,const struct timespec *restrict abstime);
作用:
        限时等待条件变量 cond 的值,线程进入睡眠状态并解锁,直到被条件变量唤醒或到达绝对时间 abstime
参数含义:
        cond:线程条件变量
        mutex:互斥锁
        abstime: 是一个绝对时间(当前时间+等待时间),表示超过这个时间将直接返回
返回值:
        成功返回 0,
        失败返回错误号

唤醒等待条件变量的线程

唤醒所有等待该条件变量的线程(pthread_cond_broadcast)

头文件:
#include <pthread.h>
函数原型:
int pthread_cond_broadcast(pthread_cond_t *cond);
作用:
        唤醒所有等待条件变量 cond 的线程
参数含义:
        cond:线程条件变量
返回值:
        成功返回 0,
        失败返回错误号

唤醒一个等待该条件变量的线程(pthread_cond_signal)

头文件:
#include <pthread.h>
函数原型:
int pthread_cond_signal(pthread_cond_t *cond);
作用:
        激活一个等待该条件 cond 的线程,存在多个等待线程时按入队顺序激活其中一个;
参数含义:
        cond:线程条件变量
返回值:
        成功返回 0,
        失败返回错误号
备注:
        在生产者消费者模型中,如果生产者一次性可以产出多个任务,那么用 pthread_cond_broadcast 好一点,如果溢出只产生一个任务,那么使用pthread_cond_signal 好一点

使用示例

#include <stdio.h>
#include <pthread.h>
static pthread_t thread1;
static pthread_t thread2;

//静态初始化
static pthread_mutex_t lock=PTHREAD_MUTEX_INITIALIZER;
static pthread_cond_t cond=PTHREAD_COND_INITIALIZER;
void *function1()
{
    while(1)
    {
        pthread_mutex_lock(&lock);
        printf("===== 线程 1 进入睡眠 ====\n");
        pthread_cond_wait(&cond,&lock);
        printf("==== 线程 1 唤醒 ====\n");
        pthread_mutex_unlock(&lock);
    }
}

void *function2()
{
    while(1)
    {
        pthread_mutex_lock(&lock);
        printf("===== 线程 2 进入睡眠 ====\n");
        pthread_cond_wait(&cond,&lock);
        printf("==== 线程 2 唤醒 ====\n");
        pthread_mutex_unlock(&lock);
    }
}

int main()
{
    int i=0;
    if(-1==pthread_create(&thread1,NULL,function1,NULL))
    {
        printf("thread_create1 fail!\n");
        pthread_detach(thread1);
    }
    if(-1==pthread_create(&thread2,NULL,function2,NULL))
    {
        printf("thread_create fail!\n");
        pthread_detach(thread1);
    }
    while(1)
    {
        sleep(2);
        i++;
        printf("\n 第%d 次唤醒\n",i);
        pthread_mutex_lock(&lock);
        if(-1==pthread_cond_signal(&cond))
        {
            printf("pthread_cond_broadcast error!\n");
        }
        pthread_mutex_unlock(&lock);
    }
    return 0;
}

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

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

相关文章

Vue2的学习

computed计算属性 概念 基于现有数据&#xff0c;计算出来的新属性&#xff0c;依赖的数据变化&#xff0c;会自动重新计算 语法 声明在computed配置项中&#xff0c;一个计算属性对应一个函数这是一个属性{{计算属性名}}&#xff0c;不是方法注意不要忘记return <body…

无涯教程-JavaScript - ROW函数

描述 ROW函数返回引用的行号。 语法 ROW ([reference]) 争论 Argument描述Required/OptionalReference 您想要其行号的单元格或单元格范围。 如果省略引用,则假定它是出现ROW函数的单元格的引用。 请参阅下面的注释。 Optional Notes 如果引用是一个单元格范围,并且如果将…

【RTOS学习】单片机中的C语言

&#x1f431;作者&#xff1a;一只大喵咪1201 &#x1f431;专栏&#xff1a;《RTOS学习》 &#x1f525;格言&#xff1a;你只管努力&#xff0c;剩下的交给时间&#xff01; 本喵默认各位小伙伴都会C语言&#xff0c;我们平时学习C语言都是在Windows环境下学习的&#xff0…

事半功倍,必看这4个Pandas神器

Pandas是我们日常处理表格数据最常用的包&#xff0c;但是对于数据分析来说&#xff0c;Pandas的DataFrame还不够直观&#xff0c;所以今天我们将介绍4个和Pandas相关的Python包&#xff0c;可以将Pandas的DataFrame转换交互式表格&#xff0c;让我们可以直接在上面进行数据分析…

【电子元件】常用电子元器件的识别之霍尔元件

目录 1. 霍尔元件的结构与特点1.1 霍尔元件的组成结构1.2 霍尔元件的霍尔效应 2. 霍尔元件的图形符号与型号2.1 1.图形符号2.2 2.型号说明 3. 半导体霍尔效应的原理3.1 半导体中的左手定则3.2 P型半导体霍尔效应的原理3.3 N型半导体霍尔效应的原理 4. 霍尔元件的电势计算与工作…

RabbitMQ深入 —— 交换机

前言 在这篇文章中&#xff0c;荔枝围绕交换机梳理RabbitMQ中交换机相关知识&#xff0c;主要包括&#xff1a;扇出交换机、直接交换机、主题交换机&#xff0c;根据不同的交换机引出相应的RabbitMQ模式。同样的本篇文章也是主要围绕如何通过交换机定向群体发送消息这一个问题来…

澳洲硕士申请QA

Q&A 申请一般问题 澳洲申请时间 澳洲分2月跟7月开学&#xff0c;不分rolling。随时申请&#xff0c;截止日期前申请就行&#xff0c;&#xff08;具体时间官网有写&#xff09; 研究生学位时长 它整体的要求一般就是如果说你要申请的这个专业是本专业&#xff0c;那他…

分类预测 | Matlab实现基于MIC-BP-Adaboost最大互信息系数数据特征选择算法结合Adaboost-BP神经网络的数据分类预测

分类预测 | Matlab实现基于MIC-BP-Adaboost最大互信息系数数据特征选择算法结合Adaboost-BP神经网络的数据分类预测 目录 分类预测 | Matlab实现基于MIC-BP-Adaboost最大互信息系数数据特征选择算法结合Adaboost-BP神经网络的数据分类预测效果一览基本介绍研究内容程序设计参考…

Linux内核中断机制

什么是中断&#xff1f; 中断是一种打断程序的正常执行流程的事件&#xff0c;这种事件以电信号的形式出现&#xff0c;可以由硬件设备或者CPU本身生成。 在中断发生后&#xff0c;正常的执行流被立即中止&#xff0c;转而执行中断处理程序(handler)。中断处理完成之后&#…

IT运维:使用数据分析平台监控Windows Eventlog

TIPS&#xff1a;本文鸿鹄版本&#xff1a;2.10.0及以上版本 概述 本文基于《IT运维&#xff1a;利用鸿鹄采集Windows event log数据》&#xff08;以下简称原文&#xff09;文章进行了细化与延伸。主要包括细化了安装步骤&#xff0c;增加了仪表板。 鸿鹄端配置 创建数据集与数…

[Linux入门]---搭建Linux环境

1.Linux环境的搭建方式 使用Linux操作系统的三种途径&#xff1a; 1.直接安装在物理机上&#xff0c;但是由于 Linux 桌面使用起来非常不友好&#xff0c;不推荐。 2.使用虚拟机软件&#xff0c;将 Linux 搭建在虚拟机上&#xff0c;但是由于当前的虚拟机软件(如 VMWare 之类的…

科研生产力:Zotero

目录 Zotero安装配置Zotero常用插件1. Zotero Connector2. Jasminum-茉莉花插件3. Zotero-scihub4. Zotero-pdf-translate5. Zotero-if6. Zotero-style7. Zotero-tag8. ZotFile9. zotero-better-notesZotero GPT 一些学习资源 Zotero安装配置 进入Zotero官网&#xff1a;https:…

前端用户体验设计:创造卓越的用户界面和交互

&#x1f482; 个人网站:【工具大全】【游戏大全】【神级源码资源网】&#x1f91f; 前端学习课程&#xff1a;&#x1f449;【28个案例趣学前端】【400个JS面试题】&#x1f485; 寻找学习交流、摸鱼划水的小伙伴&#xff0c;请点击【摸鱼学习交流群】 用户体验&#xff08;Us…

Softek Barcode Reader Toolkit 9.3 Crack

现在使用 Pdfium 读取 PDF 文件并改进了对 QRCode、PDF417 和 Code 39 的支持。 2023 年 9 月 11 日 - 16:32新版本 特征 现在使用 Pdfium 读取 PDF 文件。 提高了 GetBarStringPos 返回值的准确性。 如果 PDF417 条形码包含超过数据字节计数的符号长度描述符&#xff0c;则它会…

透视俄乌网络战之二:Conti勒索软件集团(下)

透视俄乌网络战之一&#xff1a;数据擦除软件 透视俄乌网络战之二&#xff1a;Conti勒索软件集团&#xff08;上&#xff09; Conti勒索软件集团&#xff08;下&#xff09; 1. 管理面板源代码2. Pony凭证窃取恶意软件3. TTPs4. Conti Locker v2源代码5. Conti团伙培训材料6. T…

SAP 信息类型:使用 PA30,PA20 创建,更改,复制,删除,概览

目录 创建信息类型 显示信息类型 更改信息类型 复制信息类型 删除信息类型 显示信息类型概述 创建信息类型 步骤 1&#xff09;在 SAP 命令提示符下&#xff0c;输入事务 PA30 步骤 2&#xff09;在下一个 SAP 屏幕中&#xff0c; 输入人员编号点击输入按钮 选择相关的…

SaaS软件能保证数据安全吗?

SaaS软件能保证数据安全吗&#xff1f; 本文将要尝试从各个方面尽可能客观的去阐述这个问题&#xff0c;而不是简单自嗨式的说简道云平台如何保障数据安全。 建议先收藏起来慢慢品&#xff01; 01 SaaS安全到底是什么&#xff1f;——定义解读 本文所用SaaS平台>>>…

VR航天航空巡展VR科技馆航天主题科普设备沉浸遨游太空

每当飞机飞过头顶&#xff0c;我们总是忍不住抬头去仰望。从嫦娥奔月的神话传说&#xff0c;到莱特兄弟实现了上天翱翔的梦想&#xff0c;人类一直在不断探索更辽阔的天空和浩瀚的宇宙。 航空科普 寻梦而行 普乐蛙VR航天航空巡展&#xff0c;正在湖南郴州如火如荼的进行中&…

el-dialog窗口添加滚动条

0 效果 1 代码 /deep/.addMicroDialog {height: 700px !important;overflow-y: scroll;}/deep/.addMicroDialog:hover::-webkit-scrollbar-thumb {background: #9cbaff;border-radius: 10px;}/deep/.addMicroDialog::-webkit-scrollbar {width: 6px;height: 0px;}

R--基础知识总结

R程序包的安装和加载 install.packageS(TSA) library(TSA) R向量 (vector) 数值向量 1.赋值 x<-c(1,2,3,4)assign( x,c(1,2,3,4))xc(1,2,3,4)x<-2*1:15 % x(2,4,...,30) 等差运算优先于乘法运算seq(fromvalue1,tovalue2,byvalue3) seq(length…