C++ 条件变量的使用

绪论

并发编程纷繁复杂,其中用于线程同步的主要工具——条件变量,虽然精悍,但是要想正确灵活的运用却并不容易。
对于条件变量的理解有三个难点:

  1. 为什么wait函数需要将解锁和阻塞、唤醒和上锁这两对操作编程原子的?
  2. 为什么wait函数需要配合while进行使用?
  3. 通知线程是应该先notifyunlock还是先unlocknotify

希望大家看完下面的介绍能够得到想要的答案。想要了解更多关于C++并发编程信息可以移步的我仓库:C++并发编程

条件变量

C++提供了两种条件变量的实现:std::condition_variablestd::condition_variable_any。前者只能和std::mutex配合使用,后者只需要符合互斥的标准即可。因为std::condition_variable_any更通用,所以可能产生额外的开销,如果没什么特殊需要,尽可能使用std::condition_variable

条件变量是非常重要的线程同步的手段(目前我认为是最重要的),因此对其的深入理解至关重要。

  • 条件变量总是和互斥一起配合使用,互斥用于保护共享数据,条件变量用于

    1. 通知(通知线程)
    2. 判断共享数据是否满足条件(等待线程)
  • 通知线程往往先通过互斥保护共享数据,对数据进行一定的修改后再发送通知(notify_one()、notify_all())。需要注意的是我们应尽可能在临界区内发送通知,从而避免可能出现的优先级翻转和条件变量失效问题。虽然临界区外通知可以让等待线程一旦被唤醒就能立即解锁互斥查看是否满足情况,但是在Pthread进行wait morphint后基本上两者没有性能上的差距。详细的分析可以参考博客:条件变量用例–解锁与signal的顺序问题。

    • notify_one()理论上只会唤醒一个等待线程,适用于共享变量数量发生变化的情况,例如通知消息队列中的消息个数增加。
    • notify_all()会唤醒所有等待该条件变量的线程,适用于共享变量状态发生变化的情况,例如通知所有工作线程开始计算。
  • 等待线程先获得互斥,然后将锁和判定条件传递给wait函数等待返回。

    • wait函数首先会根据判断条件判断是否满足条件(返回true

      • 如果满足条件,则直接返回(互斥依旧上锁)

      • 如果不满足条件,则阻塞等待,并解锁互斥(让其他线程得以修改共享数据的状态)。直到被notify函数唤醒,再次上锁,判断条件是否满足。这里的阻塞和解锁、唤醒和上锁都是原子的,就是为了避免两个动作分别执行出现的条件竞态。

        1. 解锁和阻塞是原子的:lock → !pred() → unlock → sleep;如果变量的改变以及唤醒事件发生在unlock和sleep中间,那么你不会检测到,也就是错过了这次唤醒。假如下次唤醒依赖于此次唤醒的成功(也就是说不会主动唤醒第二次),那么将发生死锁。
        2. 唤醒和上锁是原子的:wakeup → lock → !pred :如果条件在wakeup和lock之间从满足变成了不满足(不是因为其他等待线程修改,而是因为负责唤醒的线程自己再次修改了条件),那么此次唤醒将失败。假如后面条件的再次满足依赖于此次条件满足成功(也就是说条件不会再主动满足),那么将发生死锁。

        需要理解的是上面的死锁的出现是有限定条件的(例如唤醒之间的依赖、条件满足的依赖),虽然大多数情况下没有这么严格的条件,但是工具本身需要避免这种危险的情况。

        原子操作保证了重要的唤醒和条件满足都能够至少被一个等待线程看到。

      • 可以看到wait函数内部需要解锁互斥,所以就不能使用不提供unlock函数的lock_guard,而应该使用和互斥有相同接口的unique_lock

    • 其实C++的线程库是对pthread库的封装,因此也可以像pthread库一样只传入互斥,解锁并等待通知,一旦接收到通知后再上锁,然后在一个while循环中进行判断。

      while (!pred()) {cond_.wait(lk);  //调用pthread_cond_wait
      }
      

      对于传入判定条件的版本,其实内部也是这样的一个封装罢了。

  • 之所以说notify_one()理论上只会唤醒一个等待线程是因为存在调用一次notify_one()却唤醒了多个线程的可能性,甚至有时候没有调用notify等待线程都被唤醒,称这种意外唤醒等待线程的情况为伪唤醒。按照C++标准的规定,这种伪唤醒出现的数量和频率都不确定,因此要求等待线程的判定函数不能有副作用(可重用),并且需要在唤醒后再次判断条件是否满足,如果不满足则需要重新等待。这也是为什么上面的代码使用while进行条件判断而不是if的原因。

消息队列

//
// Created by edward on 22-11-16.
// use condtion_variable to genenrate a thread safe message queue
//#include "utils.h"
#include <mutex>
#include <queue>
#include <condition_variable>
#include <iostream>
#include <thread>
#include <string>template<typename T>
class MessageQueue {
public:void push(T t) {std::lock_guard lk(mtx_);       //互斥保护数据queue_.push(std::move(t));cond_.notify_one();				//临界区内发送通知,避免优先级反转和条件变量失效}T pop() {T frnt;std::unique_lock lk(mtx_);cond_.wait(lk, [&](){return !queue_.empty();});frnt = std::move(queue_.front());queue_.pop();return frnt;}
private:mutable std::mutex mtx_;mutable std::condition_variable cond_;std::queue<T> queue_;
};using namespace std;template<typename T>
void data_prepare(MessageQueue<T> &messageQueue) {T t;while (cin >> t) {messageQueue.push(std::move(t));}
}template<typename T>
void data_process(MessageQueue<T> &messageQueue) {T t;int idx = 0;while (true) {t = messageQueue.pop(); //数据的处理在临界区外edward::print("[", idx++, "]:", t);}
}int main() {MessageQueue<string> messageQueue;edward::print("test begin:");thread preparer(data_prepare<string>, ref(messageQueue));thread processer(data_process<string>, ref(messageQueue));preparer.join();//不用等待processer,如果preparer结束,则直接推出进程return 0;
}

运行结果

在这里插入图片描述

其中用到了我自己写的库函数头文件utils,如果想要了解更多信息可以移步C++ 工具函数库

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

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

相关文章

C++Primer学习笔记:第1章 开始

本博客为阅读《C Primer》&#xff08;第5版&#xff09;的读书笔记 ps:刚开始的时候我将所有的笔记都放在一篇博客中&#xff0c;等看到第六章的时候发现实在是太多了&#xff0c;导致我自己都不想看&#xff0c;为了日后回顾&#xff08;不那么有心理压力&#xff09;&#…

【ubuntu】ubuntu14.04上安装搜狗输入法

** 在ubuntu14.04.4 desktop 64amd版本上安装sogou输入法 ** 0.换安装源为中国源&#xff08;可选&#xff0c;下载会快些&#xff09; 1.搭fcitx环境 2.安装sogou for linux 详细步骤&#xff1a; 因为sogou中文输入法基于fcitx(Free Chinese Input Toy for X),需要先搭环境…

【ubuntu】ubuntu下用make编译程序报错找不到openssl/conf.h

ubuntu下用make编译程序报错找不到openssl/conf.h 安装libssl-dev:i386&#xff0c;sudo apt-get install libssl-dev:i386 看好版本&#xff0c;如果不加i386默认下载的是32位&#xff0c;用ln命令连接过去也还是用不了的!libssl.dev安装好后&#xff0c;用find / -name libs…

【ubuntu】ubuntu如何改变系统用户名

ubuntu如何改变系统用户名 方法1&#xff1a;修改现有用户名 方法2&#xff1a;创建新用户&#xff0c;删掉旧用户 方法1&#xff1a; * *—&#xff01;&#xff01;&#xff01;有博客说要先改密码&#xff0c;再改用户名&#xff0c;否则会出现无法登陆状况&#xff01;&…

什么是signal(SIGCHLD, SIG_IGN)函数

什么是signal(SIGCHLD, SIG_IGN)函数 在进行网络编程时候遇到这个函数的使用&#xff0c;自己学习结果如下&#xff0c;有不对请帮忙指正:) signal(SIGCHLD, SIG_IGN)打开manpage康一康~ sighandler_t signal ( int signum, sighandler_t handler );参数1 int signum: 就是…

ssh连接不上linux虚拟机

ssh连接不上linux虚拟机 1.开启ssh服务 linux虚拟机下命令行输入&#xff1a; start service ssh如果显示没有ssh&#xff0c;就下面两个试一试哪一个ok&#xff0c;安装一下ssh&#xff1a; sudo apt-get install openssh-server sudo apt-get install sshd2.还有人说可能是…

没写client,想先测试server端怎么办?

没写client&#xff0c;想先测试server端怎么办&#xff1f; 办法&#xff1a; 1.先打开终端./server&#xff0c;运行起来server 2.再开一个终端&#xff0c; 输入nc 127.0.0.1 8888 回车&#xff08;这里port号要和server里边设置的一致&#xff0c;127.0.0.1是和本机的测试…

【报错解决】linux网络编程报错storage size of ‘serv_addr’ isn’t known解决办法

linux网络编程报错storage size of ‘serv_addr’ isn’t known解决办法 报错如下&#xff1a; server.c:18:21: error: storage size of ‘serv_addr’ isn’t known struct sockaddr_in serv_addr, clit_addr; ^server.c:18:32: error: storage size of ‘clit_addr’ isn’…

【c】写头文件要加#ifndef,#define, #endif

头文件首位 编写.h时&#xff0c; 最好加上如下&#xff0c;用来防止重复包含头文件&#xff1a; 例如&#xff1a; 要编写头文件test.h 在头文件开头写上两行&#xff1a;#ifndef _TEST_H#define _TEST_H// 文件名的大写#endif头文件结尾写上一行&#xff1a;#endif这样做是为…

【c】【报错解决】incompatible implicit declaration

【报错解决】incompatible implicit declaration 背景; 1.自己封装的函数wrap.c包含&#xff1a; #include "wrap.h"2.主函数调用如下&#xff1a; #include <stdio.h> #include <stdlib.h> ... #include <errno.h> #include "wrap.h"…

【ubuntu】vim语法高亮设置无效

如果你的.vimrc配置了语法高亮&#xff0c;但是你的vim没实现&#xff0c;可能你的vim是vim-tiny的黑白版本&#xff0c;你需要vim-gnome这个带GUI的彩色版本。 apt-get update apt-get upgrade apt-get install vim-gnome reboot打开vi就能看到彩色啦

__attribute__机制介绍

1. __attribute__ GNU C的一大特色&#xff08;却不被初学者所知&#xff09;就是__attribute__机制。 __attribute__可以设置函数属性(Function Attribute)、变量属性(Variable Attribute)和类型属性(Type Attribute) __attribute__前后都有两个下划线&#xff0c;并且后面会紧…

【git】git基本操作命令

1.建立本地仓库 git config --global user.name "lora" git config --global user.email "xxxgmail.com"2.建立目录 mkdir xxx3.初始化 cd xxx //进入目录 git init //初始化4.将代码上传至本地缓存区 git add . //上传全部 git add 文件名 //…

【git】解决gitlab ip更改问题

有时候因为部署gitlab虚拟机的ip发生变化&#xff0c;gitlab的clone地址没有同时更新到新的ip&#xff0c; 这导致后续clone报错&#xff0c;解决办法如下&#xff1a; 进入部署gitlab的主机&#xff1a; sudo vim /opt/gitlab/embedded/service/gitlab-rails/config/gitlab.…

gcc -l参数和-L参数

-l参数就是用来指定程序要链接的库&#xff0c;-l参数紧接着就是库名&#xff0c;那么库名跟真正的库文件名有什么关系呢&#xff1f;就拿数学库来说&#xff0c;他的库名是m&#xff0c;他的库文件名是libm.so&#xff0c;很容易看出&#xff0c;把库文件名的头lib和尾.so去掉…

【jenkins】jenkins CI/CD搭建基本过程

1.安装 &#xff08;1&#xff09;安装java &#xff08;2&#xff09;安装jenkins &#xff08;3&#xff09;修改jenkins用户名密码配置 &#xff08;4&#xff09;启动jenkins 2. 插件安装换源 &#xff08;1&#xff09;插件高级选项换地址 &#xff08;2&#xff09;修改…

apt-get常用命令

一&#xff0c;什么的是apt-get 高级包装工具&#xff08;英语&#xff1a;Advanced Packaging Tools,简称&#xff1a;APT&#xff09;是Debian及其衍生发行版&#xff08;如&#xff1a;ubuntu&#xff09;的软件包管理器。APT可以自动下载&#xff0c;配置&#xff0c;安装二…

【jenkins】jenkins build项目的三种方式

jenkins致力于CI/CD&#xff0c; 更改代码只需要在gitlab push之后&#xff0c;jenkins重新build便可以在tomcat上实现更新部署。 以下为三种构建方式&#xff1a; 1.freestyle project 0. 安装插件Deploy to container, 并安装凭证 github连接创建item设置build和post-build …

apt-get 使用详解

[举例] 目前常用的 *更新本机中的数据库缓存&#xff1a; sudo apt-get update *查找包含部分关键字的软件包&#xff1a; sudo apt-cache search <你要查找的name> *安装指定的软件&#xff1a; sudo apt-get install <你要安装的软件包> *下载软件包源代码&…

Buildroot用户指南

第一章 关于Buildroot Buildroot是一个包含Makefile和修补程序【patch】的集合&#xff0c;这个集合可以使你很容易的为你的目标构建交叉工具链【cross-compilationtoolchain】&#xff0c;根文件系统【root filesystem】以及Linux内核映像【kernelimage】。Buildroot可…