C++20协程示例

C++20协程示例

认识协程

在C++中，协程就是一个可以暂停和恢复的函数。

包含co_wait、co_yield、co_return关键字的都可以叫协程。

看一个例子：

MyCoroGenerator<int> testFunc(int n)
{std::cout << "Begin testFunc" << std::endl;for (int i = 0; i < n; ++i) {std::cout << "TestFunc before yield " << i << std::endl;co_yield i;std::cout << "TestFunc after yield " << i << std::endl;}std::cout << "End testFunc" << std::endl;
}int main()
{int inp = 10;std::cout << "Before testFunc" << std::endl;MyCoroGenerator<int> gen = testFunc(inp);std::cout << "After testFunc" << std::endl;for (int i = 0; i < inp; ++i) {std::cout << "Cur input: " << i << std::endl;std::cout << "Output value: " << gen.next() << std::endl;std::cout << "After input: " << i << std::endl;}
}

上面这段代码的执行结果是：

Before testFunc
After testFunc
Cur input: 0
Output value: Begin testFunc
TestFunc before yield 0
0
After input: 0
Cur input: 1
Output value: TestFunc after yield 0
TestFunc before yield 1
1
After input: 1
Cur input: 2
Output value: TestFunc after yield 1
TestFunc before yield 2
2
After input: 2
Cur input: 3
Output value: TestFunc after yield 2
TestFunc before yield 3
3
After input: 3
Cur input: 4
Output value: TestFunc after yield 3
TestFunc before yield 4
4
After input: 4
Cur input: 5
Output value: TestFunc after yield 4
TestFunc before yield 5
5
After input: 5...

调用时发现，函数并没有一开始就执行，而是等到next时才开始执行。执行到co_yield就会自动暂停，下次next才会继续执行

另外，函数本身并没有返回什么，但是这里可以使用MyCoroGenerator<int>接收。函数的控制权也转移到了MyCoroGenerator<int>，需要执行时就调用next。

函数在暂停后执行，依然可以继续上次的状态，这是因为，协程在挂起期间，其上下文全部都被保留，下次执行时恢复。

协程句柄

std::coroutine_handle类模板是实现协程的最底层的工具，负责存储协程的句柄。他可以特化为std::coroutine_handle<Promise>或者std::coroutine_handle<void>。

这里面的Promise是实现协程必要的Promise类，而且其名字必须是promise_type。

协程会暂停，其上下文也会保留，std::coroutine_handle就是保存和管理协程的地方。

std::coroutine_handle中方法不多，但是每个都很重要，其中：

  • done方法，可以查询协程是否已经结束
  • resume，恢复一个协程的执行
  • destroy，销毁一个协程

std::coroutine_handle是一个很底层的东西，没有RAII包裹，就像一个裸指针那样，需要手动创建、手动销毁。

所以需要一个包裹类，负责处理协程句柄的初始化和销毁，也就是Generator

Generator

C++的协程要求Generator必须有promise_type这个类，名字也必须这个，不能是其他的名字，直接定义在Generator中最方便。

template <typename T>
struct MyCoroGenerator {struct promise_type {// todo};
};

promise_type中有一些固定接口，这些接口如果不实现，那么协程是不完整的。

  • initial_suspend，协程是否在初始化结束后挂起，返回std::suspend_always、std::suspend_never，这是标准库里面已经定义好的类型，前者表示总是挂起，后者表示从不挂起
  • final_suspend，协程最后一次执行是否挂起，返回值和上面函数相同。由于final_suspend是收尾阶段的工作，所以必须是noexcept
  • unhandled_exception，处理协程中未被处理的异常
  • get_return_object，返回一个Generator对象
  • yield_value，处理协程返回值，就是co_yield传递过来的值
  • return_void，处理协程结束后的返回值，和return_value同时只能存在一个，如果没有返回值就用return_void
  • return_value，处理协程结束后返回值，和return_void同时只能存在一个，如果有返回值就用return_value

解释一下yield_value函数，co_yield实际是一个语法糖，相当于co_wait promise.yield_value(i)，只有实现了该函数，Genreator才能接收co_yield的返回值

函数的返回值，需要回答协程要不要挂起，也就是std::suspend_always或者std::suspend_never，因为需要yield后挂起，所以返回std::suspend_always。

为了接收返回值，需要用转发和std::optional，接收并存储返回值。

get_return_object负责创建一个Generator，一般来说，使用std::coroutine_handle<promise_type>::from_promise接口从一个Promise创建句柄，然后使用这个句柄创建Generator。

为了配合创建函数，MyGenerator需要实现一个接收句柄的构造函数。也就是MyCoroGenerator(std::coroutine_handle<promise_type> h)

#include <coroutine>
#include <iostream>
#include <optional>template <typename T>
struct MyCoroGenerator {/*** @brief C++协程要求Generator必须有promise_type这个类型，名字也必须是promise_type* 最方便的方法就是定义在Generator类内部**/struct promise_type {/*** @brief 存放协程返回值* 由Generator从获取并返回*/std::optional<T> opt;/*** @brief 协程是否创建时就被挂起，函数名字也必须是initial_suspend* std::suspend_always、std::suspend_never是标准库里面已经定义好的类型，前者表示总是挂起，后者表示从不挂起** @return std::suspend_always 协程创建即挂起*/std::suspend_always initial_suspend() const{return {};}/*** @brief 协程最后一次执行是否挂起，函数名字也必须是final_suspend* 由于final_suspend是收尾阶段的工作，所以必须是noexcept** @return std::suspend_always 协程最后一次执行也被挂起*/std::suspend_always final_suspend() const noexcept{return {};}/*** @brief 处理协程中未捕获异常，函数名字必须是unhandled_exception**/void unhandled_exception(){std::exit(EXIT_FAILURE);}/*** @brief 获取一个Generator对象，该对象从promise_type构造** @return MyCoroGenerator*/MyCoroGenerator get_return_object(){return MyCoroGenerator { std::coroutine_handle<promise_type>::from_promise(*this) };}/*** @brief 定制yield_value接口，接收co_yield返回的值** @tparam Arg 值的类型* @param arg co_yield返回值* @return std::suspend_always 执行完后继续挂起*/template <typename Arg>std::suspend_always yield_value(Arg&& arg){opt.emplace(std::forward<Arg>(arg));return {};}/*** @brief 当协程结束co_return且没有返回值时，调用该函数* 还有一个return_value(expr)函数，负责处理协程结束且有返回值的情况*/void return_void(){}};/*** @brief 协程句柄，存储了协程上下文，一个非常底层的东西，没有RAII* 用MyCoroGenerator包裹*/std::coroutine_handle<promise_type> handle;/*** @brief 默认构造函数**/MyCoroGenerator() = default;/*** @brief 通过一个handle构造一个Generator** @param h 从promise_type构造出来的协程句柄*/MyCoroGenerator(std::coroutine_handle<promise_type> h): handle(h){}/*** @brief 移动构造函数** @param other 其他Generator对象*/MyCoroGenerator(MyCoroGenerator&& other){if (handle) {handle.destroy();}handle = other.handle;other.handle = nullptr;}/*** @brief 析构函数**/~MyCoroGenerator(){if (handle) {handle.destroy();}}/*** @brief 移动赋值函数** @param other 其他Generator对象* @return MyCoroGenerator& 当前镀锡*/MyCoroGenerator& operator=(MyCoroGenerator&& other){if (handle) {handle.destroy();}handle = other.handle;other.handle = nullptr;return *this;}/*** @brief 继续执行协程，并返回执行结果** @return T& 返回的值*/T& next(){handle.resume();if (handle.done()) {// throw geneator_done("Generator done");throw "Generator Error";}return *(handle.promise().opt);}private:MyCoroGenerator(const MyCoroGenerator&) = delete;MyCoroGenerator& operator=(const MyCoroGenerator&) = delete;
};

源码

#include <coroutine>
#include <iostream>
#include <optional>template <typename T>
struct MyCoroGenerator {/*** @brief C++协程要求Generator必须有promise_type这个类型，名字也必须是promise_type* 最方便的方法就是定义在Generator类内部**/struct promise_type {/*** @brief 存放协程返回值* 由Generator从获取并返回*/std::optional<T> opt;/*** @brief 协程是否创建时就被挂起，函数名字也必须是initial_suspend* std::suspend_always、std::suspend_never是标准库里面已经定义好的类型，前者表示总是挂起，后者表示从不挂起** @return std::suspend_always 协程创建即挂起*/std::suspend_always initial_suspend() const{return {};}/*** @brief 协程最后一次执行是否挂起，函数名字也必须是final_suspend* 由于final_suspend是收尾阶段的工作，所以必须是noexcept** @return std::suspend_always 协程最后一次执行也被挂起*/std::suspend_always final_suspend() const noexcept{return {};}/*** @brief 处理协程中未捕获异常，函数名字必须是unhandled_exception**/void unhandled_exception(){std::exit(EXIT_FAILURE);}/*** @brief 获取一个Generator对象，该对象从promise_type构造** @return MyCoroGenerator*/MyCoroGenerator get_return_object(){return MyCoroGenerator { std::coroutine_handle<promise_type>::from_promise(*this) };}/*** @brief 定制yield_value接口，接收co_yield返回的值** @tparam Arg 值的类型* @param arg co_yield返回值* @return std::suspend_always 执行完后继续挂起*/template <typename Arg>std::suspend_always yield_value(Arg&& arg){opt.emplace(std::forward<Arg>(arg));return {};}/*** @brief 当协程结束co_return且没有返回值时，调用该函数* 还有一个return_value(expr)函数，负责处理协程结束且有返回值的情况*/void return_void(){}};/*** @brief 协程句柄，存储了协程上下文，一个非常底层的东西，没有RAII* 用MyCoroGenerator包裹*/std::coroutine_handle<promise_type> handle;/*** @brief 默认构造函数**/MyCoroGenerator() = default;/*** @brief 通过一个handle构造一个Generator** @param h 从promise_type构造出来的协程句柄*/MyCoroGenerator(std::coroutine_handle<promise_type> h): handle(h){}/*** @brief 移动构造函数** @param other 其他Generator对象*/MyCoroGenerator(MyCoroGenerator&& other){if (handle) {handle.destroy();}handle = other.handle;other.handle = nullptr;}/*** @brief 析构函数**/~MyCoroGenerator(){if (handle) {handle.destroy();}}/*** @brief 移动赋值函数** @param other 其他Generator对象* @return MyCoroGenerator& 当前镀锡*/MyCoroGenerator& operator=(MyCoroGenerator&& other){if (handle) {handle.destroy();}handle = other.handle;other.handle = nullptr;return *this;}/*** @brief 继续执行协程，并返回执行结果** @return T& 返回的值*/T& next(){handle.resume();if (handle.done()) {// throw geneator_done("Generator done");throw "Generator Error";}return *(handle.promise().opt);}private:MyCoroGenerator(const MyCoroGenerator&) = delete;MyCoroGenerator& operator=(const MyCoroGenerator&) = delete;
};MyCoroGenerator<int> testFunc(int n)
{std::cout << "Begin testFunc" << std::endl;for (int i = 0; i < n; ++i) {std::cout << "TestFunc before yield " << i << std::endl;co_yield i;std::cout << "TestFunc after yield " << i << std::endl;}std::cout << "End testFunc" << std::endl;
}int main()
{int inp = 10;std::cout << "Before testFunc" << std::endl;MyCoroGenerator<int> gen = testFunc(inp);std::cout << "After testFunc" << std::endl;for (int i = 0; i < inp; ++i) {std::cout << "Cur input: " << i << std::endl;std::cout << "Output value: " << gen.next() << std::endl;std::cout << "After input: " << i << std::endl;}
}

参考：C++ coroutine generator 实现笔记

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

如若内容造成侵权/违法违规/事实不符，请联系一条长河网进行投诉反馈，一经查实，立即删除！

相关文章

RHCE---Web 服务器

RHCE---Web 服务器

文章目录 目录 文章目录 前言 一.Web服务器概述 网址及HTTP协议概述&#xff1a; HTTP协议请求过程&#xff1a; 二.搭建动态HTTP网页 动态网页概述&#xff1a; 搭建动态的HTTP协议网页&#xff1a; 总结 前言 通过上一个章节的学习了解了时间服务器以及远程连接服务器&a…
阅读更多...
C++中实现雪花算法来在秒级以及毫秒及时间内生成唯一id

C++中实现雪花算法来在秒级以及毫秒及时间内生成唯一id

1、雪花算法原理 雪花算法&#xff08;Snowflake Algorithm&#xff09;是一种用于生成唯一ID的算法&#xff0c;通常用于分布式系统中&#xff0c;以确保生成的ID在整个分布式系统中具有唯一性。它的名称来源于雪花的形状&#xff0c;因为生成的ID通常是64位的整数&#xff0…
阅读更多...
Prometheus-Rules 实战

Prometheus-Rules 实战

文章目录 1 node rules2 nginx rule2.1 Nginx 4xx 错误率太多2.2 Nginx 5xx 错误率太多2.3 Nginx 延迟高 3 mysql rule3.1 MySQL 宕机3.2 实例连接数过多3.3 MySQL高线程运行3.4 MySQL 从服务器 IO 线程没有运行3.5 MySQL 从服务器 SQL 线程没有运行3.6 MySQL复制滞后3.7 慢查询…
阅读更多...
作为SiteGPT替代品，HelpLook的优势是什么？

作为SiteGPT替代品，HelpLook的优势是什么？

在当今快节奏的数字化世界中&#xff0c;企业不断寻求创新方式来简化运营并增强客户体验。由于聊天机器人能够自动化任务、提供快速响应并提供个性化互动&#xff0c;它们在业务运营中的使用变得非常重要。因此&#xff0c;企业越来越意识到像SiteGPT和HelpLook这样高效的聊天机…
阅读更多...
I/O

I/O

IO 流简介 IO 即 Input/Output&#xff0c;输入和输出。数据输入到计算机内存的过程即输入&#xff0c;反之输出到外部存储&#xff08;比如数据库&#xff0c;文件&#xff0c;远程主机&#xff09;的过程即输出。IO 流在 Java 中分为输入流和输出流&#xff0c;而根据数据的…
阅读更多...
Spring事务不生效的场景的解决方案

Spring事务不生效的场景的解决方案

一、前言 在Java Web开发中&#xff0c;使用Spring框架可以大大简化开发人员的工作。其中&#xff0c;事务管理是Spring框架中的一个重要功能&#xff0c;它可以确保多个数据库操作要么全部成功&#xff0c;要么全部失败。但是&#xff0c;在实际开发中&#xff0c;我们可能会…
阅读更多...
基于微信小程序的明星应援小程序设计与实现(源码+lw+部署文档+讲解等)

基于微信小程序的明星应援小程序设计与实现(源码+lw+部署文档+讲解等)

文章目录 前言系统主要功能&#xff1a;具体实现截图论文参考详细视频演示为什么选择我自己的网站自己的小程序&#xff08;小蔡coding&#xff09;有保障的售后福利 代码参考源码获取 前言 &#x1f497;博主介绍&#xff1a;✌全网粉丝10W,CSDN特邀作者、博客专家、CSDN新星计…
阅读更多...
浅谈研发与制造运营双端之间的数字化探索

浅谈研发与制造运营双端之间的数字化探索

一、传统中小型制造企业的发展变革与信息化建设背景 以往&#xff0c;传统的中小型制造企业常以大批量、重复性生产制造为主&#xff0c;依赖于人力设备&#xff0c;通过扩大产能发展壮大&#xff0c;信息化能力弱。伴随市场环境的变化及厂商竞争压力&#xff0c;企业谋生存求…
阅读更多...
【网络八股】TCP八股

【网络八股】TCP八股

网络八股 请简述TCP/IP模型中每层的作用&#xff0c;典型协议和典型设备介绍一下三次握手的过程介绍一下四次挥手的过程必须三次握手吗&#xff0c;两次不行吗&#xff1f;为什么ACK数据包消耗TCP的序号吗三次握手中可以携带应用层数据吗四次挥手时&#xff0c;可以携带应用层数…
阅读更多...
UE蓝图学习(从Unity3D而来)

UE蓝图学习(从Unity3D而来)

一、UE组件对比Unity3D&#xff0c;从Unity3D过渡来学的角度出发&#xff0c;可以理解为在 空物体下放置子物体。UE没有U3D那种可以将组件挂在自身空物体上面。 二、UE 蓝图的情境提示&#xff0c;必须先找到相应的类型&#xff0c;对象对象、事件事件&#xff0c;才能找到相应…
阅读更多...
Vue iconfont-阿里巴巴矢量图标库用法

Vue iconfont-阿里巴巴矢量图标库用法

一、vue使用 选择心仪的图标 加入购物车 点击右上角购物车&#xff0c;点击添加至项目 在资源管理 可以看到我的项目 进入项目设置勾选彩色 点击下载到本地 解压压缩包 在main.js文件内导入css文件 import "/assets/font_icon/iconfont.css"; 使用&#xff1a; 复…
阅读更多...
Hive 数据仓库介绍

Hive 数据仓库介绍

目录 ​编辑 一、Hive 概述 1.1 Hive产生的原因 1.2 Hive是什么&#xff1f; 1.3 Hive 特点 1.4 Hive生态链关系 二、Hive架构 2.1 架构图 2.2 架构组件说明 2.2.1 Interface 2.2.1.1 CLI 2.2.1.2 JDBC/ODBC 2.2.1.3 WebUI 2.2.2 MetaData 2.2.3 MetaStore 2.2…
阅读更多...
postman怎么进行参数化？

postman怎么进行参数化？

一、先准备好参数化数据 &#xff08;参数化数据可以使用Excel或者txt的文件。 注意如果使用的是txt的文件&#xff0c;一定要使用英文的逗号&#xff0c;不然的话会报错&#xff01;&#xff09; 注意&#xff1a;填写好的数据后&#xff0c;保存的时候需要另存为&#xff0c…
阅读更多...
PayPal面经

PayPal面经

文章目录 初战AI Infra团队广泛收集信息&#xff0c;增加对面试相关团队的了解Paypal的AI infra Engineer 极客时间演讲视频&#xff1a;AI在金融应用HR面试首面 zhang chao首先让我介绍自己和项目基础知识出题 lettcode 1and0s 二面 luwen没有让我重复介绍自己那好&#xff0c…
阅读更多...
如何快速重置模型原点

如何快速重置模型原点

1、什么是模型原点&#xff1f; 模型原点是三维建模中的概念&#xff0c;它是指在一个虚拟三维空间中确定的参考点。模型原点通常位于模型的几何中心或基本组件的中心位置。如图所示&#xff1a; 可以看到模型的原点在模型的几何中心 2、模型原点的作用 知道了什么是模型原点&…
阅读更多...
LCR 101. 分割等和子集——力扣——背包问题、动态规矩

LCR 101. 分割等和子集——力扣——背包问题、动态规矩

问题描述 代码展示 class Solution:def canPartition(self, nums: List[int]) -> bool:if len(nums) < 1:return Falsetotal_sum sum(nums)if total_sum % 2 ! 0: # 总和为奇数&#xff0c;无法分成两个相等的子集return Falsetarget_sum total_sum // 2dp [[False]…
阅读更多...
myArm 全新七轴桌面型机械臂

myArm 全新七轴桌面型机械臂

引言 在不断演进的科技世界中&#xff0c;我们始终追求创新和卓越&#xff0c;以满足客户的需求并超越他们的期望。今天&#xff0c;我们很高兴地宣布我们的最新产品——myArm 300 Pi&#xff0c;一款七轴的桌面型机械臂。这款产品的独特之处在于其灵活性和可编程性&#xff0c…
阅读更多...
Docker——容器生命周期管理（下篇）

Docker——容器生命周期管理（下篇）

Docker 一、run1、options说明2、-p的三种写法3、实例14、实例25、实例36、实例47、实例58、实例69、实例78、实例89、退出容器 二、start/stop/restart1、语法格式2、stop/restart 命令的 options 三、kill1、重点2、说明3、实例 四、rm1、说明2、实例 五、create实例 六、exe…
阅读更多...
天眼查询企业信息API接口

天眼查询企业信息API接口

"天眼"一般是指"天眼查"&#xff0c;这是一个提供全国企业信息查询的API接口。天眼查以"天眼"作为用户logo&#xff0c;基于人工智能算法的数据采集和分析技术&#xff0c;为企业和个人提供全量、精准、实时、权威的企业信息查询服务。 天眼查A…
阅读更多...
美容店预约小程序搭建流程

美容店预约小程序搭建流程

随着科技的不断发展&#xff0c;小程序已经成为了人们生活中不可或缺的一部分。对于美容店来说&#xff0c;搭建一个预约小程序不仅可以提高工作效率&#xff0c;还可以增加客户数量、提高服务质量。那么&#xff0c;如何搭建一个美容店预约小程序呢&#xff1f;本文将为你详细…
阅读更多...
最新文章

Copyright @ 2022~2023