c++20中的jthread再谈

一、介绍

在前面的C++20新功能中,简单的介绍过相关的std::jthread的应用。当时觉得它虽然比std::thread方便一些,但也没有多大的优势。可在后面的不断的学习中,发现std::jthread的使用上确实有优秀之处,相对于传统的线程编程,等于是提前安全的封装了对线程安全管理和控制的相关模块和接口。

二、std::jthread应用

一般来说对线程的应用主要有以下几类:
1、线程管理
线程管理,就是对线程的按需启动和安全退出有一个最基础的要求,在std::thread中可以通过线程分离和Join来控制线程的安全退出,使用一些变量来处理线程中循环的退出。但这些在std::jthread中都有了安全的应用机制:
线程启动:直接启动即可。
线程退出处理:自动合并joining,这个没什么可说的。
线程停止控制:线程取消使用std::stop_token和std::stop_source。std::stop_source负责维护线程的共享停止状态,提供了一种发出停止线程的请求方法。它可以与std::stop_token与std::stop_callback共同工作。std::stop_token可以理解成一种对线程退出状态的查看(查看关联的std::stop_source),如果满足条件就退出。
其实线程的启动还相对好控制一些,特别是线程的退出,一般对初学者来说,都是比较难以驾驭的,经常是线程退出整个程序也崩溃了。所以std::jthread提供的这个退出控制还是不错的。

2、条件变量
在多线程编程中,Linux环境下使用条件变量的很多,但在C++20中配合std::condition_variable_any,则会更加方便。std::condition_variable_any比std::condition_variable应用更广泛,而不只是局限于对 std::unique_lockstd::mutex的控制,意味着能支持更多的锁机制。

#include <condition_variable>
#include <iostream>
#include <mutex>
#include <thread>void testConditionAny(std::stop_token sToken) {std::mutex mutex;std::unique_lock lock(mutex);// cv_any::wait内部含std::stop_token的重载,当sToken停止会调用cv_any的唤醒动作std::condition_variable_any().wait(lock, sToken, [] {//这个谓词类似于处理假唤醒的bool值return false;});std::cout << "jthread function testConditionAny quit!" << std::endl;
}
int main() {//jthread的RAII封装会调用request_stop()std::jthread testAny(testConditionAny);std::this_thread::sleep_for(std::chrono::seconds(1));return 0;
}

其实这个和普通的condition_variable的用法是一致的。

3、回调处理
如果说上面的“条件变量”和std::jthread没有必然联系,但在线程中的回调还是相当重要的。在C++20中针对std::jthread则提供了一个回调std::stop_callback类。这个有一个细节需要注意,如果是此回调执行了,则在关联的 std::stop_token 的std::stop_source 调用了 request_stop() 的同一线程中调用。否则在构造的线程中执行。

三、例程

先看一个stop_source的例程:

#include <chrono>
#include <iostream>
#include <stop_token>
#include <thread>using namespace std::chrono_literals;void worker_fun(int id, std::stop_source stop_source)
{std::stop_token stoken = stop_source.get_token();for (int i = 10; i; --i){std::this_thread::sleep_for(300ms);if (stoken.stop_requested()){std::printf("  工作线程%d 被请求停止\n", id);return;}std::printf("  工作线程%d 返回睡眠\n", id);}
}int main()
{std::jthread threads[4];std::cout << std::boolalpha;auto print = [](const std::stop_source& source){std::printf("stop_source stop_possible = %s, stop_requested = %s\n",source.stop_possible() ? "true" : "false",source.stop_requested() ? "true" : "false");};// 普通停止信号源std::stop_source stop_source;print(stop_source);// 创建工作线程for (int i = 0; i < 4; ++i)threads[i] = std::jthread(worker_fun, i + 1, stop_source);std::this_thread::sleep_for(500ms);std::puts("请求停止");stop_source.request_stop();print(stop_source);// 注意:jthreads 的析构函数会调用 join,因此无需显式调用
}

运行结果:

stop_source stop_possible = true, stop_requested = false工作线程2 返回睡眠工作线程3 返回睡眠工作线程1 返回睡眠工作线程4 返回睡眠
请求停止
stop_source stop_possible = true, stop_requested = true工作线程3 被请求停止工作线程1 被请求停止工作线程2 被请求停止工作线程4 被请求停止

再看一个回调函数的:

#include <chrono>
#include <condition_variable>
#include <iostream>
#include <mutex>
#include <sstream>
#include <thread>using namespace std::chrono_literals;// 使用一个辅助类进行原子 std::cout 流输出。
class Writer {std::ostringstream buffer;public:~Writer() { std::cout << buffer.str(); }Writer &operator<<(auto input) {buffer << input;return *this;}
};int main() {// 工作线程。// 它将等待直至被请求停止。std::jthread worker([](std::stop_token stoken) {Writer() << "工作线程 id: " << std::this_thread::get_id() << '\n';std::mutex mutex;std::unique_lock lock(mutex);std::condition_variable_any().wait(lock, stoken, [&stoken] { return stoken.stop_requested(); });});// 在工作线程上注册停止回调。std::stop_callback callback(worker.get_stop_token(),[] { Writer() << "执行了停止回调,线程: " << std::this_thread::get_id() << '\n'; });// 可以提前销毁 stop_callback 对象以阻止其执行。{std::stop_callback scoped_callback(worker.get_stop_token(), [] {// 这里不会执行。Writer() << "作用域内的停止回调被执行,线程: " << std::this_thread::get_id() << '\n';});}// 演示由哪个线程何时执行 stop_callback。// 定义停止函数。auto stopper_func = [&worker] {std::cout << std::this_thread::get_id() << '\n';if (worker.request_stop())Writer() << "执行了停止请求,线程: " << std::this_thread::get_id() << '\n';elseWriter() << "未执行停止请求,线程: " << std::this_thread::get_id() << '\n';};// 使多个线程竞争以停止工作线程。std::jthread stopper1(stopper_func);std::jthread stopper2(stopper_func);stopper1.join();stopper2.join();// 已经请求停止后,立即执行新的 stop_callback。Writer() << "主线程: " << std::this_thread::get_id() << '\n';std::stop_callback callback_after_stop(worker.get_stop_token(), [] { Writer() << "执行了停止回调,线程: " << std::this_thread::get_id() << '\n'; });
}

执行结果:

工作线程 id: 140149702784576
140149694391872
140149685999168
执行了停止回调,线程: 140149694391872
执行了停止请求,线程: 140149694391872
未执行停止请求,线程: 140149685999168
主线程: 140149709902784
执行了停止回调,线程: 140149709902784

需要知道的是,stop_token 的获取可以从stop_source得到也可以从std::jthread得到,都有相关的获取API接口。
注:代码来自cppreference

四、总结

目前很少听说在实际工程中有应用jthread的,可能大家觉得thread就比较好用,也可能是开发习惯和代码惯性的问题。std::jthread需要支持的版本也比较高得到c++20,估计这也是一个非常重要的原因。毕竟,现在C++11都没有真正普及开来,很多开发者仍然只是使用一些非常简单的新特性。
还是要追上来,与是俱进!

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

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

相关文章

大数据学习-2024/3/30-MySQL基本语法使用介绍实例

学生信息表 create table studend(stu_id int primary key auto_increment comment 学生学号,stu_name varchar(20) not null comment 学生名字,mobile char(11) unique comment 手机号码,stu_sex char(3) default 男 comment 学生性别,birth date comment 出生日期,stu_time …

《操作系统导论》第15章读书笔记:机制:地址转换(address translation)

《操作系统导论》第15章读书笔记&#xff1a;机制&#xff1a;地址转换&#xff08;address translation&#xff09; —— 杭州 2024-03-30 夜 文章目录 《操作系统导论》第15章读书笔记&#xff1a;机制&#xff1a;地址转换&#xff08;address translation&#xff09;1.前…

正点原子imx6ull-mini不使用网络更新内核系统

参考视频&#xff1a;【【正点原子】Linux网络环境搭建篇】 参考文档&#xff1a;从正点原子官方下载 这几天在学imx6ull写网络驱动检测出网卡&#xff0c;但是一直ping不通ubuntu&#xff0c;电脑还有ubuntu、开发板都处于同一个网段&#xff0c;跟着正点原子的视频试了双网…

新一代信息技术元年汇总

元年汇总&#xff1a; 大数据 1998 区块链 2008 云计算 2012 RPA 2018 移动通信技术&#xff08;5G的元年&#xff09; 2019

DW1000 定位技术解析

Qorvo 的 DW1000 是一款完全集成的单芯片超宽带 (UWB) 低功耗、低成本收发器 IC&#xff0c;符合 IEEE 802.15.4a 标准。它可用于 2 向测距或 TDoA 定位系统&#xff0c;以 10 厘米的精度定位资产。它还支持速率高达 6.8 Mbps 的数据传输。DW1000 由一个包含一个接收器137和一个…

flutter Got socket error trying to find package nested at

flutter Got socket error trying to find package nested at xxx 报错信息&#xff1a;“Got socket error trying to find package nested at” 通常出现在Flutter尝试从pub.dev获取依赖包时&#xff0c;由于网络问题导致无法连接到pub.dev或者无法正确解析包的路径。 例如&…

2_1.Linux中的网络配置

#1.什么是IP ADDRESS# internet protocol ADDRESS ##网络进程地址 ipv4 internet protocol version 4 ip是由32个01组成 11111110.11111110.11111110.11111110 254.254.254.254 #2.子网掩码# 用来划分网络区域 子网掩码非0的位对应的ip上的数字表示这个ip的网络位 子网掩码0位…

S7-1500PLC与ABB机器人RobotStudio调试演示

(1)建立空工作站 (2)选择机器人、导入吸盘、托盘、传送带 (3) 将导入的吸盘变为工具 (4)创建机器人系统 布局如下 (5)创建物体 (6)设置物体本地原点 (7)创建传送带Smart组件

单例设计模式(2)

单例设计模式&#xff08;2&#xff09; 单例模式存在的问题 单例对 OOP 特性的支持不友好 oop的特性&#xff1a;封装、继承、多态、抽象&#xff1b;以Id生成器代码为例&#xff0c;如果未来某一天&#xff0c;我们希望针对不同的业务采用不同的 ID 生成算法。比如&#x…

通过多选按钮选择需要修改什么字段

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 前言一、代码 前言 想要更新什么字段就将该字段更新&#xff0c;第一想到通过多选框控制&#xff0c;通过一系列的尝试&#xff0c;做了如下的布局和功能 直接上代…

[操作系统课设]GeeKOS操作系统的研究与实现

一.GeekOS操作系统概论 1.1教学操作系统 &#xff08;1&#xff09;针对RISC结构MIPS处理器 操作系统&#xff1a;Nachos、OS/161 &#xff08;2&#xff09;针对CISC结构Intel IA-32 (or x86)通用处理 操作系统&#xff1a;MINIX、GeekOS 我们用到的是&#xff1a;GeekOS 1&…

二分(二段性)

本文用于记录个人算法竞赛学习&#xff0c;仅供参考 一.二分算法 二分算法一般用于具有二段性的问题&#xff0c;数据不一定具有单调性&#xff0c;所以单调可二分&#xff0c;可二分不一定就要单调。 二.整数二分 1. 模板一&#xff1a;将区间[l, r]划分为[l, mid] 和 [mid…

字符串(KMP)

P3375 【模板】KMP - 洛谷 | 计算机科学教育新生态 (luogu.com.cn) #include<iostream> #include<algorithm> #include<cstdio> #include<cstring> using namespace std; #define ll long long const int N1e6100; int n0,m; char s1[N]; char s2[N];…

36.HarmonyOS鸿蒙系统 App(ArkUI) 创建第一个应用程序hello world

36.HarmonyOS App(ArkUI) 创建第一个应用程序helloworld 线性布局 1.鸿蒙应用程序开发app_hap开发环境搭建 3.DevEco Studio安装鸿蒙手机app本地模拟器 打开DevEco Studio,点击文件-》新建 双击打开index.ets 复制如下代码&#xff1a; import FaultLogger from ohos.fau…

通俗易懂Redis缓存穿透,缓存击穿,缓存雪崩

1.1 缓存穿透 原因&#xff1a;当我们查询一个数据的时候&#xff0c;缓存中没有&#xff0c;就会去查询我们的关系型数据库&#xff0c;而且查询不到的数据是不会放到我们的缓存中&#xff0c;就会导致我们每次的请求都会来到我们的关系型数据库中&#xff0c;从而导致关系型…

代码随想录刷题day39|不同路径不同路径II

文章目录 day39学习内容一、不同路径2.1、动态规划五部曲1.1.1、 确定dp数组&#xff08;dp table&#xff09;以及下标的含义1.1.2、确定递推公式1.1.3、 dp数组如何初始化1.1.4、确定遍历顺序1.1.5、计算并返回最终结果 1.2、代码 二、不同路径II2.1、动态规划五部曲2.1.1、 …

使用Flink实现Kafka到MySQL的数据流转换:一个基于Flink的实践指南

使用Flink实现Kafka到MySQL的数据流转换 在现代数据处理架构中&#xff0c;Kafka和MySQL是两种非常流行的技术。Kafka作为一个高吞吐量的分布式消息系统&#xff0c;常用于构建实时数据流管道。而MySQL则是广泛使用的关系型数据库&#xff0c;适用于存储和查询数据。在某些场景…

小米SU7 我劝你再等等

文 | AUTO芯球 作者 | 李逵 我必须承认我一时没忍住 犯错了 我不会被我老婆打吧 感觉有点慌呀 这不前两天 我刚提了台问界M9嘛 但是昨晚看小米汽车发布会 是真的被雷总感染到了 真的没忍住 我又冲了台小米SU7 Pro版 本来我是准备抢创始版的 结果1秒钟时间 点进去就…

yolov5 v7.0打包exe文件,使用C++调用

cd到yolo5文件夹下 pyinstaller -p 当前路径 -i logo图标 detect.py问题汇总 运行detect.exe找不到default.yaml 这个是yolov8里的文件 1 复制权重文件到exe所在目录。 2 根据报错提示的配置文件路径&#xff0c;把default.yaml复制放到相应的路径下。&#xff08;缺少相应…

杨辉三角形(c++实现)

题目 下面的图形是著名的杨辉三角形&#xff1a; 如果我们按从上到下、从左到右的顺序把所有数排成一列&#xff0c;可以得到如下数列&#xff1a; 1, 1, 1, 1, 2, 1, 1, 3, 3, 1, 1, 4, 6, 4, 1, … 给定一个正整数 N&#xff0c;请你输出数列中第一次出现 N 是在第几个数&a…