详解c++20的协程,自定义可等待对象,生成器详解

协程

c++20的协程三大标签:“性能之优秀”,“开发之灵活”,“门槛之高”

在讲解c++的协程使用前,我们需要先明白协程是什么,协程可以理解为用户态的线程,它需要由程序来进行调度,如上下文切换与调度设计都需要程序来设计,并且协程运行在单个线程中,这就成就了协程的低成本,更直接一点的解释可以说,协程就是一种可以被挂起与恢复的特殊函数。
协程并不会真正地“脱离”当前的线程,它只是让控制流从一个函数流转到另一个地方,然后再回来。这个过程是 轻量级非阻塞 的。
协程可以分为两种类型对称型与非对称型协程:

  • 非对称协程:控制权的转移是单向的,总是从调用者协程转移到被调用者协程,并且被调用者协程必须将控制权返回给调用者协程。
  • 对称协程:控制权可以在任意两个协程之间直接转移。协程在执行过程中可以选择将控制权交给其他任何协程,而不依赖于特定的调用层次关系。

c++协程的基本概念

c++提供的协程是典型的非对称协程,c++中的协程有两个特定条件:

  1. 协程函数必须包含至少一个协程关键字(co_awaitco_yieldco_return
    • co_await: 主要用于暂停协程的执行,同时等待某个异步操作完成。在协程执行到 co_await 表达式时,它会将控制权交还给调用者,待异步操作完成后,协程再恢复执行。
    • co_yield: 主要用于生成器模式,它会产生一个值,然后暂停协程的执行。每次调用生成器的迭代器时,协程会恢复执行,直到下一个 co_yield 或者协程结束。
    • co_return: 用于结束协程的执行,并返回一个值(如果协程有返回类型)。当协程执行到 co_return 时,它会销毁自身的栈帧,并将控制权交还给调用者。
      这里先简单介绍协程的基本概念和使用,后面会结合更多代码解释每一个点
  2. 返回值必须是实现了promise_type结构体的一个类或者结构体;
struct Task {struct promise_type {Task get_return_object() { return {}; }std::suspend_never initial_suspend() { return {}; }std::suspend_never final_suspend() noexcept { return {}; }void return_void() {}void unhandled_exception() {}};
};Task task() {std::cout << "Starting coroutine operation..." << std::endl;co_await std::suspend_always{};std::cout << "Coroutine operation completed." << std::endl;
}int main() {task();std::cout << "Main function continues..." << std::endl;return 0;
}// 输出
Starting coroutine operation...
Main function continues...

这个代码简单演示了协程的使用,我们可以看到输出只有两条,并没有输出Coroutine operation completed.,这个程序的运行流程是main函数调用task后,先保存当前上下文,再将当前线程的上下文切换成task的,接下来输出一条内容运行到co_await时,再次保存当前上下文,不过这次会将上下文切换回协程的调用者也就是main,我们后续没有再回到task运行最后一条命令,这里也就没有相关输出了
协程函数的返回类型有特殊要求。返回类型主要用于表示协程的句柄或包装器,它提供了一种方式来管理协程的生命周期,以及与协程进行交互。promise_type主要用来定义协程的生命周期和行为。

  • promise_type必须实现以下关键方法:
    • get_return_object():该函数在协程开始执行之前被调用,其作用是返回协程的返回对象
    • initial_suspend():在协程开始执行时调用,用于决定协程是否在开始时就暂停。std::suspend_never 表示协程不会在开始时暂停,会立即执行。
    • final_suspend():在协程结束执行时调用,用于决定协程是否在结束时暂停。std::suspend_never 表示协程不会在结束时暂停,会立即销毁。
    • unhandled_exception():处理未捕获的异常。
      下面的方法可选
  • return_void() 当调用co_return时会触发这个函数,它触发于final_suspend()之前
  • yield_value() 主要用于生成器返回值
    我们再来明确一下调用时刻,get_return_object()是在协程运行前就被调用了,当存放task();这一行时就会调用get_return_object()函数,因为我们这个演示比较简单不会返回如何东西,我们会在下面的演示中详细介绍,initial_suspend()是在协程开始执行时调用,这个时刻是介于get_return_object()与真正开始运行之间的时候,这些函数名必须一模一样

生成器

template<typename T>
struct Generator {struct promise_type {T value_;auto get_return_object() { return Generator{this}; }auto initial_suspend() noexcept { return std::suspend_always{}; }auto final_suspend() noexcept { return std::suspend_always{}; }void unhandled_exception() { std::terminate(); }auto yield_value(T val) {value_ = val;return std::suspend_always{};}};using Handle = std::coroutine_handle<promise_type>;Handle handle_;explicit Generator(promise_type* p) : handle_(Handle::from_promise(*p)) {}~Generator() { if (handle_) handle_.destroy(); }T next() {if (!handle_.done()) handle_.resume();return handle_.promise().value_;}
};// 斐波那契生成器
Generator<int> fibonacci() {int a = 0, b = 1;while (true) {co_yield a;int temp = a;a = b;b = temp + b;}
}int main() {auto fib = fibonacci();for (int i = 0; i < 10; ++i) {std::cout << fib.next() << " "; }
}// 输出 
0 1 1 2 3 5 8 13 21 34

这个代码使用了一种叫做生成器的特殊类,它需要我们自己实现,作用是获得一次协程的返回值,fibonacci中使用co_yield返回了a,之前我们介绍过co_yield它的作用是,产生一个值然后暂停协程的执行
这里的promise_type结构体多了两个东西,yield_value()函数的作用是把传入的值存储到 value_ 中,并且返回 std::suspend_always{},使得协程暂停。当使用co_yield关键字时就相当于调用了这个函数,T value_用于存放我们的返回值
promise_type结构体外的东西,都是我们可以自定义的这里最重要的就是,代码中的std::coroutine_handle<>,它是一个协程句柄表示一个协程实例的句柄,允许开发者手动控制协程的恢复、销毁或访问其内部状态,它通常实现为一个指针,直接指向协程的状态帧 ,C++20 协程机制中的核心工具类,用于直接操作协程的生命周期和执行流程。它提供了一种底层但灵活的方式来管理协程的状态。我们介绍几个常用的函数

  • Handle::from_promise() 这是一个静态成员函数,用于从 promise_type 对象创建一个协程句柄。在协程的 promise_type 中,通常会使用这个函数来获取协程句柄,以便在返回对象中保存。
  • resume() 恢复协程的执行。如果协程当前处于暂停状态,调用这个函数会让协程从暂停点继续执行,直到下一个暂停点或者协程结束。
  • destroy() 销毁协程,释放协程占用的资源。在协程执行完毕或者不再需要时,应该调用这个函数来避免内存泄漏。
  • bool done() 检查协程是否已经完成。如果协程已经执行完毕,返回 true;否则返回 false
  • promise_type& promise() 返回与协程句柄关联的 promise_type 对象的引用。通过这个引用,你可以访问和修改协程的状态和数据。
    next()函数用于返回值并恢复协程的执行,这里我们通过get_return_object()构建并返回我们的生成器

自定义可等待对象

自定义可等待对象需要满足特定的接口要求,主要涉及await_readyawait_suspendawait_resume这三个成员函数。

  • await_ready:用于判断是否可以立即恢复协程的执行。若返回true,协程会马上恢复;若返回false,协程就会被挂起。
  • await_suspend:在协程挂起时调用,这里可以执行异步操作。在示例中,使用一个新线程来模拟异步操作,操作完成后恢复协程。
  • await_resume:在协程恢复执行时调用,返回异步操作的结果。
template <typename T>
struct FutureAwaitable {std::future<T>& future;bool await_ready() const noexcept {return future.wait_for(std::chrono::seconds(0)) == std::future_status::ready;}void await_suspend(std::coroutine_handle<> handle) const {std::thread([this, handle]() mutable {future.wait();handle.resume();}).detach();}T await_resume() {return future.get();}
};template <typename T>
FutureAwaitable<T> co_awaitable(std::future<T>& future) {return {future};
}struct AsyncTask {struct promise_type {std::promise<int> promise;std::future<int> result = promise.get_future();auto get_return_object() { return AsyncTask{this}; }auto initial_suspend() { return std::suspend_never{}; }auto final_suspend() noexcept { return std::suspend_always{}; }void return_value(int val) {promise.set_value(val);}void unhandled_exception() {std::terminate();}};using Handle = std::coroutine_handle<promise_type>;Handle handle_;explicit AsyncTask(promise_type* p) : handle_(Handle::from_promise(*p)) {}~AsyncTask() {if (handle_) {handle_.destroy();}}int get() {return handle_.promise().result.get();}
};AsyncTask simulate_async_io() {auto future = std::async([] {std::this_thread::sleep_for(std::chrono::seconds(1));return 42;});auto result = co_await co_awaitable(future);co_return result;
}int main() {auto task = simulate_async_io();std::cout << "Waiting..." << std::endl;std::cout << "Result: " << task.get() << std::endl; // 输出: 42return 0;
}

这个代码演示了co_await结合自定义等待对象,实现的异步调用,当我们触发co_await时会等待异步操作的完成,并获得返回值,在等待时协程会挂起让出cpu资源
await_suspend()函数中我们在另一个线程中恢复了协程,协程的执行线程由恢复它的线程决定。handle.resume() 是恢复协程执行的关键操作,它会从协程上次挂起的位置接着执行。由于 handle.resume() 是在新创建的 std::thread 线程里被调用的,所以协程恢复后会继续在这个新线程里执行后续代码。
return_value()yield_value()函数类似,它是用来处理co_return关键字的返回值的

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

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

相关文章

JavaEE企业级开发 延迟双删+版本号机制(乐观锁) 事务保证redis和mysql的数据一致性 示例

提醒 要求了解或者熟练掌握以下知识点 spring 事务mysql 脏读如何保证缓存和数据库数据一致性延迟双删分布式锁并发编程 原子操作类 前言 在起草这篇博客之前 我做了点功课 这边我写的是一个示例代码 数据层都写成了 mock 的形式(来源于 JUnit5) // Dduo import java.u…

A2 最佳学习方法

记录自己想法的最好理由是发现自己的想法&#xff0c;并将其组织成可传播的形式 (The best reason for recording what one thinks is to discover what one thinks and to organize it in transmittable form.) Prof Ackoff 经验之谈&#xff1a; 做培训或者写文章&#xff…

嵌入式硬件工程师从小白到入门-PCB绘制(二)

PCB绘制从小白到入门&#xff1a;知识点速通与面试指南 一、PCB设计核心流程 需求分析 明确电路功能&#xff08;如电源、信号处理、通信&#xff09;。确定关键参数&#xff08;电压、电流、频率、接口类型&#xff09;。 原理图设计 元器件选型&#xff1a;匹配封装、电压、…

vue创建子组件步骤及注意事项

在 Vue 中创建子组件需要遵循组件化开发的核心原则&#xff0c;并注意数据流、通信机制、复用性等关键点。以下是详细步骤和注意事项&#xff0c;结合代码示例说明&#xff1a; 一、创建子组件的步骤 1. 定义子组件 创建一个 .vue 文件&#xff08;单文件组件&#xff09;&am…

Cocos Creator版本发布时间线

官网找不到&#xff0c;DeepSeek给的答案&#xff0c;这里做个记录。 Cocos Creator 1.x 系列 发布时间&#xff1a;2016 年 - 2018 年 1.0&#xff08;2016 年 3 月&#xff09;&#xff1a; 首个正式版本&#xff0c;基于 Cocos2d-x 的 2D 游戏开发工具链&#xff0c;集成可…

【Spring AI】基于专属知识库的RAG智能问答小程序开发——功能优化:用户鉴权主体功能开发

系列文章目录 【Spring AI】基于专属知识库的RAG智能问答小程序开发——完整项目&#xff08;含完整前端后端代码&#xff09;【Spring AI】基于专属知识库的RAG智能问答小程序开发——代码逐行精讲&#xff1a;核心ChatClient对象相关构造函数【Spring AI】基于专属知识库的R…

【AI神经网络】深度神经网络(DNN)技术解析:从原理到实践

引言 深度神经网络&#xff08;Deep Neural Network, DNN&#xff09;作为人工智能领域的核心技术&#xff0c;近年来在计算机视觉、自然语言处理、医疗诊断等领域取得了突破性进展。与传统机器学习模型相比&#xff0c;DNN通过多层非线性变换自动提取数据特征&#xff0c;解决…

目标跟踪——deepsort算法详细阐述

deepsort 算法详解 Unmatched Tracks(未匹配的轨迹) 本质角色: 是已存在的轨迹在当前帧中“失联”的状态,即预测位置与检测结果不匹配。 生命周期阶段: 已初始化: 轨迹已存在多帧,可能携带历史信息(如外观特征、运动模型)。 未被观测到: 当前帧中未找到对应的检测框…

Vue-admin-template安装教程

#今天配置后台管理模板发现官方文档的镜像网站好像早失效了&#xff0c;自己稍稍总结了一下方法# 该项目环境需要node17及以下&#xff0c;如果npm install这一步报错可能是这个原因 git clone https://github.com/PanJiaChen/vue-admin-template.git cd vue-admin-template n…

Rust从入门到精通之进阶篇:14.并发编程

并发编程 并发编程允许程序同时执行多个独立的任务&#xff0c;充分利用现代多核处理器的性能。Rust 提供了强大的并发原语&#xff0c;同时通过类型系统和所有权规则在编译时防止数据竞争和其他常见的并发错误。在本章中&#xff0c;我们将探索 Rust 的并发编程模型。 线程基…

算法训练营第二十三天 | 贪心算法(一)

文章目录 一、贪心算法理论基础二、Leetcode 455.分发饼干二、Leetcode 376. 摆动序列三、Leetcode 53. 最大子序和 一、贪心算法理论基础 贪心算法是一种在每一步选择中都采取当前状态下的最优决策&#xff0c;从而希望最终达到全局最优解的算法设计技术。 基本思想 贪心算…

css基础-display 常用布局

CSS display 属性详解 属性设置元素是否被视为块级或行级盒子以及用于子元素的布局&#xff0c;例如流式布局、网格布局或弹性布局。 一、基础显示模式 1. block 作用&#xff1a; 元素独占一行可设置宽高和内外边距默认宽度撑满父容器 应用场景&#xff1a; 布局容器&a…

速卖通API数据清洗实战:从原始JSON到结构化商品数据库

下面将详细介绍如何把速卖通 API 返回的原始 JSON 数据清洗并转换为结构化商品数据库。 1. 数据获取 首先要借助速卖通 API 获取商品数据&#xff0c;以 Python 为例&#xff0c;可使用requests库发送请求并得到 JSON 数据。 import requests# 替换为你的 API Key 和 Secret …

【零基础入门unity游戏开发——2D篇】2D物理系统 —— 2D刚体组件(Rigidbody2D)

考虑到每个人基础可能不一样,且并不是所有人都有同时做2D、3D开发的需求,所以我把 【零基础入门unity游戏开发】 分为成了C#篇、unity通用篇、unity3D篇、unity2D篇。 【C#篇】:主要讲解C#的基础语法,包括变量、数据类型、运算符、流程控制、面向对象等,适合没有编程基础的…

Collectors.toMap / list 转 map

前言 略 Collectors.toMap List<User> userList ...; Map<Long, User> userMap userList.stream().collect(Collectors.toMap(User::getUserId, Function.identity()));假如id存在重复值&#xff0c;则会报错Duplicate key xxx, 解决方案 两个重复id中&#…

热门面试题第13天|Leetcode 110.平衡二叉树 257. 二叉树的所有路径 404.左叶子之和 222.完全二叉树的节点个数

222.完全二叉树的节点个数&#xff08;优先掌握递归&#xff09; 需要了解&#xff0c;普通二叉树 怎么求&#xff0c;完全二叉树又怎么求 题目链接/文章讲解/视频讲解&#xff1a;https://programmercarl.com/0222.%E5%AE%8C%E5%85%A8%E4%BA%8C%E5%8F%89%E6%A0%91%E7%9A%84%E8…

关于Object.assign

Object.assign 基本用法 Object.assign() 方法用于将所有可枚举属性的值从一个或者多个源对象source复制到目标对象。它将返回目标对象target const target { a: 1, b: 2 } const source { b: 4, c: 5 }const returnedTarget Object.assign(target, source)target // { a…

GitHub高级筛选小白使用手册

GitHub高级筛选小白使用手册 GitHub 提供了强大的搜索功能&#xff0c;允许用户通过高级筛选器来精确查找仓库、Issues、Pull Requests、代码等。下面是一些常用的高级筛选用法&#xff0c;帮助你更高效地使用 GitHub 搜索功能。 目录 搜索仓库搜索Issues搜索Pull Requests搜…

手动集成sqlite的方法

注意到sqlite有backup方法&#xff08;https://www.sqlite.org/backup.html&#xff09;。 也注意到android中sysroot下&#xff0c;没有sqlite3的库&#xff0c;也没有相关头文件。 如果要使用 sqlite 的backup&#xff0c;那么就需要手动集成sqlite代码到项目中。可以如下操…

蓝桥杯真题 2109.统计子矩阵

原题地址:1.统计子矩阵 - 蓝桥云课 问题描述 给定一个 NMNM 的矩阵 AA, 请你统计有多少个子矩阵 (最小 1111, 最大 NM)NM) 满足子矩阵中所有数的和不超过给定的整数 KK ? 输入格式 第一行包含三个整数 N,MN,M 和 KK. 之后 NN 行每行包含 MM 个整数, 代表矩阵 AA. 输出格…