c++20 std::jthread 源码简单赏析与应用

std::jthread

说明:

std::jthread 是 C++20 中引入的一个新特性,它是线程库中的一个类,专门用于处理 std::thread 与 std::stop_token 和 std::stop_source 之间的交互,以支持更优雅和安全的线程停止机制。

std::stop_source控制线程标记。相当于g_bQuitFlag = true;

std::stop_token线程函数内检测结束标记。相当于while(!g_bQuitFlag){...};

作用1.可控制的线程结束,防止人工封装的线程结束控制变量不是线程安全的。2.线程结束后不必手工调用join();

源码简单赏析:

C:\Program Files (x86)\Microsoft Visual Studio\2019\Enterprise\VC\Tools\MSVC\14.29.30133\include\thread

下面代码可以复制出来浏览。

class jthread {
public:using id = thread::id;using native_handle_type = thread::native_handle_type;jthread() noexcept : _Impl{}, _Ssource{ nostopstate } {}template <class _Fn, class... _Args, enable_if_t<!is_same_v<remove_cvref_t<_Fn>, jthread>, int> = 0>_NODISCARD_CTOR explicit jthread(_Fn&& _Fx, _Args&&... _Ax) {if constexpr (is_invocable_v<decay_t<_Fn>, stop_token, decay_t<_Args>...>) //线程函数第一个参数为stop_token,如果客户端std::jthread jt(work, stop_source.get_token());使用自己的stop_source展开相当于//is_invocable_v<decay_t<_Fn>, stop_token, stop_token>为false,执行下面else为不使用this->_Ssource,这里很微妙!//如果客户端std::jthread jt(work);不使用自己的stop_source展开相当于is_invocable_v<decay_t<_Fn>, stop_token>为true//也就是说这个if判断了三种情况,1.线程函数第一个不为stop_token 2.线程函数第一个参数为stop_token且客户端使用自己的stop_source //3.线程函数第一个参数为stop_token且客户端使用不自己的stop_source{_Impl._Start(_STD forward<_Fn>(_Fx), _Ssource.get_token(), _STD forward<_Args>(_Ax)...);//按照使用this内置的stop_source::stop_token传给线程函数}else {_Impl._Start(_STD forward<_Fn>(_Fx), _STD forward<_Args>(_Ax)...);//按照std::thread处理,不使joinable功能,那么this->request_stop();也无效。处于兼容性考虑吧}}~jthread() {_Try_cancel_and_join();//析构时可自动调用_Impl.joinable();_Ssource.request_stop();_Impl.join();}jthread(const jthread&) = delete;//不支持拷贝构造jthread(jthread&&) noexcept = default;//jthread依然是unique thread类型的jthread& operator=(const jthread&) = delete;//不支持赋值jthread& operator=(jthread&& _Other) noexcept {// note: the standard specifically disallows making self-move-assignment a no-op here// N4861 [thread.jthread.cons]/13// Effects: If joinable() is true, calls request_stop() and then join(). Assigns the state// of x to *this and sets x to a default constructed state._Try_cancel_and_join();//移动赋值时,先结束掉本线程,再移动源线程到this_Impl = _STD move(_Other._Impl);_Ssource = _STD move(_Other._Ssource);return *this;}//剩下的简单函数封装void swap(jthread& _Other) noexcept {_Impl.swap(_Other._Impl);_Ssource.swap(_Other._Ssource);}_NODISCARD bool joinable() const noexcept {return _Impl.joinable();}void join() {_Impl.join();}void detach() {_Impl.detach();}_NODISCARD id get_id() const noexcept {return _Impl.get_id();}_NODISCARD stop_source get_stop_source() noexcept {return _Ssource;}_NODISCARD stop_token get_stop_token() const noexcept {return _Ssource.get_token();}bool request_stop() noexcept {return _Ssource.request_stop();}friend void swap(jthread& _Lhs, jthread& _Rhs) noexcept {_Lhs.swap(_Rhs);}_NODISCARD static unsigned int hardware_concurrency() noexcept {return thread::hardware_concurrency();}private:void _Try_cancel_and_join() noexcept {if (_Impl.joinable()) {_Ssource.request_stop();_Impl.join();}}thread _Impl;//采用c++组合方式对std::thread进行薄薄的封装,是不是和std::queue差不多的方法?stop_source _Ssource;//使用std自己实现的原子操作类std::stop_source控制线程停止
};

应用:

根据源代码阅读衍生的几个例子。源代码和例子说的是一致的。

1.不使用jthread内置的stop_source相当于thread类,std::jthread::request_stop();将不起作用,方便于一个外置std::stop_source控制多个线程函数

#include <iostream>
#include <thread>
#include <chrono>void work(std::stop_token stop_token) {while (!stop_token.stop_requested()) {std::cout << "Working...\n";std::this_thread::sleep_for(std::chrono::seconds(1));}std::cout << "Stopping...\n";
}int main() {std::stop_source stop_source;std::jthread jt(work, stop_source.get_token());std::this_thread::sleep_for(std::chrono::seconds(3));stop_source.request_stop();return 0;
}

2.使用jthread内置的stop_source :

#include <iostream>
#include <thread>
#include <chrono>void work(std::stop_token stop_token) {while (!stop_token.stop_requested()) {std::cout << "Working...\n";std::this_thread::sleep_for(std::chrono::seconds(1));}std::cout << "Stopping...\n";
}int main() {std::jthread jt(work);std::this_thread::sleep_for(std::chrono::seconds(3));//这两行都没必要人工调用的jt.request_stop();//jt.join();//return 0;
}

3.当线程函数参数没有参数stop_token时,使用起来std::jthread::request_stop();不起作用。相当于std::thread:

#include <iostream>
#include <thread>
#include <chrono>void work() {while (1) {std::cout << "Working...\n";std::this_thread::sleep_for(std::chrono::seconds(1));}std::cout << "Stopping...\n";
}int main() {std::jthread jt(work);std::this_thread::sleep_for(std::chrono::seconds(3));jt.request_stop();jt.join();return 0;
}
//输出:
//Working...
//Working...
//Working...
//Working...
//...

结论:

功能过于强大,灵活,坑也比较多。功能少,呆板,也没有什么坑。其实没有什么坑,只不过没看过开源库源码。官方文档不足以表达,就像黑盒测试永远无法相当于白盒测试。常常碰一碰运气运行一下看起来没问题,黑盒看起来也没问题?官方文档std::jthread - cppreference.com

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

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

相关文章

微软开发者大会:编程进入自然语言时代、“AI员工”闪亮登场

当地时间周二&#xff0c;美国科技公司微软召开年度Build开发者大会。在CEO纳德拉的带领下&#xff0c;微软各个产品团队再一次展现出惊人的执行力&#xff0c;在发布会上又拿出了接近50个新产品或功能更新。 整场发布会持续了接近两个小时&#xff0c;在这里挑选了一些投资者…

web自动化文件上传弹框处理

目录 文件上传介绍文件上传处理Alert 弹窗介绍Alert 弹窗处理 课程目标 掌握文件上传的场景以及文件上传的处理方式。掌握 Alert 弹窗的场景以及 Alert 弹窗的处理方式。 思考 碰到需要上传文件的场景&#xff0c;自动化测试应该如何解决&#xff1f; 文件上传处理 找到文…

el-switch自动触发更新事件

比如有这样一个列表&#xff0c;允许修改单条数据的状态。希望在更改el-switch状态时能够有个弹框做二次确认&#xff0c;没问题&#xff0c;el-switch已经帮我们想到了&#xff0c;所以它提供了beforeChange&#xff0c;根据beforeChange的结果来决定是否修改状态。一般确认修…

【python】串口双向透传python小程序

串口双向透传python小程序 import serial import threadingdef serial_forward(source, dest):while True:data source.read()dest.write(data)def main():# 串口1设置serial_port1 serial.Serial(COM9, 9600, timeout1)# 串口2设置serial_port2 serial.Serial(COM30, 9600…

递归,进程fork(),以及线程clone()之间的比较

在计算机科学中&#xff0c;处理复杂任务的常见方法有递归、进程&#xff08;通过 fork 创建&#xff09;&#xff0c;以及线程&#xff08;通过 clone 创建&#xff09;。这三种方式各有其独特的优势和适用场景。在本文中&#xff0c;我们将深入比较这三种方法&#xff0c;并展…

React Native 之 定义全局状态管理库(九)

假设你正在使用基于单页面应用&#xff08;SPA&#xff09;的微前端框架。以下简化一个应用之间共享状态的例子。 1. 使用发布/订阅模式 // globalStateManager.js class GlobalStateManager { constructor() { this.subscribers {}; this.state {}; } subscribe(key…

计算机缺失ffmpeg.dll如何修复,五种详细的修复教程分享

当你在使用电脑过程中&#xff0c;突然遇到系统或软件弹出提示信息&#xff0c;告知“ffmpeg.dll文件丢失”怎么办&#xff1f;当电脑提示ffmpeg.dll丢失时&#xff0c;可能会导致一些应用程序无法正常运行或出现错误提示。下面我将介绍5种解决电脑提示ffmpeg.dll丢失的方法。 …

String.intern()方法有什么作用

String.intern() 是一个 native&#xff08;本地&#xff09;方法&#xff0c;其作用是将指定的字符串对象的引用保存在字符串常量池中。字符串池是一个存储字符串字面量的固定池&#xff0c;它的主要目的是为了减少内存使用和提高性能。 当你调用intern()方法时&#xff0c;如…

神秘山洞惊现AI绘画至宝Stable Diffusion残卷

最近听到不少大宗门纷纷发声&#xff1a;随着AI神器的现世“程序员职业将不复存在”&#xff0c;“设计图将要失业”。 至此&#xff0c;不少修士开始担忧起来&#xff0c;现出世的AI神器会不会取代掉我辈修士。 其实&#xff0c;至女娲天神创造人类以来&#xff0c;在这漫漫…

Android软件渲染流程

Android软件渲染流程 一.渲染流程1.VSync信号的监听2.VSync信号触发绘制 二.渲染原理1.画布的获取1.1 渲染缓存的初始化1.2 graphics::Canvas的创建1.3 graphics::Canvas与渲染缓存的绑定1.3.1 SkBitmap的初始化1.3.2 SkiaCanvas与SkBitmap的绑定1.3.3 SkCanvas的创建 2.矩形的…

C++ (week4):Linux基础

文章目录 零、Linux简介1.配置环境2.Linux历史3.Linux模型 一、vim二、Linux命令行 (shell命令)1.常用命令与快捷键(1)常用命令①man命令&#xff1a;查看帮助手册 (2)快捷键 2.用户子系统(1)Linux用户(2)用户命令 3.文件子系统命令(1)目录命令1.创建文件&#xff1a;mkdir2.删…

flink读kafka写mysql数据库

场景:从kafka读数据,通过jdbc写入mysql 示例: #往kafka测试主题写入数据 kafka-console-producer.sh --broker-list wh01t:21007 --topic ypg_test --producer.config /client/Kafka/kafka/config/producer.properties –创建mysql测试表 – dsg.test definition CREATE TABL…

【AI绘画Stable Diffusion】单人LoRA模型训练,打造你的专属模型,新手入门宝典请收藏!

大家好&#xff0c;我是灵魂画师向阳 本期我将教大家如何进行LoRA模型训练&#xff0c;打造你的专属模型&#xff0c;内容比较干&#xff0c;还请耐心看完&#xff01; 随着AIGC的发展&#xff0c;许多传统工作岗位正逐渐被AI取代。同时&#xff0c;AI变革也在创造前所未有的…

ftp是什么,ftp能做什么,ftp有什么用 -----ftp介绍

大家好&#xff0c;我是风屿&#xff0c;今天开始我会给大家介绍一些关于网络方面的配置以及介绍等等&#xff0c;今天是ftp FTP中文名字叫做文件传输协议&#xff0c;英文名字叫做File Transfer Protocol&#xff08;简称为ftp&#xff09; FTP 是因特网网络上历史最悠久的网…

JS 实战 贪吃蛇游戏

一、css 部分 1. 居中 想要开始和暂停两个按钮居中&#xff0c;可以将盒子设置为弹性盒 也可以使用其他方法 【代码】 2. 将父元素设置为相对定位&#xff0c;偏于之后贪吃蛇长长的身子&#xff0c;是以父元素为基点的绝对定位&#xff0c;通过 left 和 top 来控制位置 二、…

富甲美国---沃尔玛创始人山姆·沃尔顿

富甲美国---沃尔玛创始人山姆沃尔顿_山姆沃尔顿是犹太人吗?-CSDN博客文章浏览阅读786次。​1.不断地检讨回顾我们做得好不好或需要改进的&#xff0c;我们从没有对现况满足过。我们会短暂地大肆庆祝成功&#xff0c;然后认真地检讨下次如何能做得更好---不断改进与创新。2我们…

数据挖掘导致直接路径读(direct path read)耗尽了IO

一大早就有喊业务卡的&#xff0c;检查等待事件源头&#xff0c;均为oracle写等待 查看IO负载持续维持在100%繁忙 后台有两个并行rman备份在&#xff0c;停止备份io繁忙没有好转&#xff0c;检查最近ash报告&#xff0c;发现DDTEK ODBC Oracle程序模块占用最高 检查该模块&…

阿里云、百度云和移动云的对象存储横向性能对比

文章目录 前言一、对比测试的方法和标准A. 测试环境的设置 二、对比测试的结果A、阿里云OSS测试结果2.B. 百度云结果C. 移动云结果分析与结论 总结 前言 在企业的数字化转型进程中&#xff0c;我们观察到越来越多的公司将其IT基础设施迁移到云端。随着企业业务的持续运营&…

音视频安卓主板记录仪手持终端定制开发_基于MT6762平台解决方案

音视频安卓主板采用了基于MT6762高性能处理器芯片的设计&#xff0c;其中包括4个主频高达2.0GHz的Cortex-A53核心和4个主频1.5GHz的Cortex-A53高效聚焦核心&#xff0c;可提供无比流畅的体验。搭载Android 12操作系统&#xff0c;系统版本进行了全新的优化&#xff0c;进一步确…

linux 错误记录(三)

这里的内核源码路径&#xff1a; cd /usr/src/linux-headers-5.4.0-150-generic/ 内核版本&#xff1a; $ uname -r 5.4.0-150-generic 错误现象 ./include/uapi/asm-generic/int-ll64.h:12:10: fatal error: asm/bitsperlong.h: No such file or directory 搜索后是有的 …