百度360必应搜狗淘宝本站头条
当前位置:网站首页 > 技术教程 > 正文

如何编写 C++ 20 协程(Coroutines)

mhr18 2025-05-28 18:49 12 浏览 0 评论

C++20 带着 Coroutines 来了!

花了一两周的时间后,我想写写 C++20 协程的基本用法,因为 C++ 的协程让我感到很奇怪,写一个协程程序十分费劲。让我们抛去复杂的东西,来看看写一个 C++ 协程需要哪些东西。

编译器支持

由于 C++ 20 还没被所有编译器完全支持,首先需要确保你的编译器实现了 Coroutines,可以通过下面的网站查看编译器支持情况:https://en.cppreference.com/w/cpp/compiler_support#cpp20

值得一提,我使用的 MacOS 自带的 Apple Clang 对 C++20 支持很弱,我选择通过 Homebrew 安装最新版的 GNU GCC (10 以上版本)来编译。

我使用的 GNU GCC 10.2 版本编译指令:

g++ -fcoroutines -std=c++20

Clang 支持不够好,不推荐使用。Clang 可以使用如下命令编译:

clang++ -std=c++20 -stdlib=libc++ -fcoroutines-ts

不推荐 Clang 还有一个理由:使用 Clang 需要 include 头文件 <experimental/coroutine> 而不是 <coroutine>。此外,一些类型被命名为 std::experimental:xxx 而不是 std:xxx

以下示例代码只支持 GNU GCC 版本的编译器。

C++ 协程简介

在正式开始之前,我们先要理解 C++20 中协程使用的一些术语。

首先,什么是协程?

协程就是一个可以挂起(suspend)恢复(resume)的函数(但无论如何不能是 main 函数)。你可以暂停协程的执行,去做其他事情,然后在适当的时候恢复到暂停的位置继续执行。协程让我们使用同步方式写异步代码

怎么挂起协程呢?C++ 提供了三个方法:co_await, co_yieldco_return

顺便说一句:coroutine 不是并行(parallelism),和 Go 语言的 goroutine 不一样!

与你之前接触到的协程完全不同,一个 C++ 协程一般长这样:

这奇怪的协程代码涉及了 C++ 协程很重要的三个概念:

  • promise_type

  • Awaitable

  • std::coroutine_handle<>

在写 C++20 的协程之前,我们必须需要先了解三个概念,可以用这三张图来形容这三个概念:

图来源: https://www.youtube.com/watch?v=vzC2iRfO_H8

Promise

C++ 协程的返回类型必须是 promise_typepromise_type 是一个 interface,你可以用它来控制协程,在协程的生命周期中注入自定义行为:

  • get_return_object:控制协程的返回对象

  • initial_suspend:在协程开始的时候挂起

  • final_suspend:在协程结束的时候挂起

协程的生命周期如下,用户自定义的函数 <function-body> 被包裹在下面的伪代码中(来源:http://eel.is/c++draft/dcl.fct.def.coroutine#5):

可以看到,initial_suspend 会在进入协程(也就是函数)之前执行,final_suspend 会在协程返回之前执行。

如果 final_suspend 真的挂起了协程,那么作为协程的调用者,你需要手动的调用 destroy 来释放协程;如果 final_suspend 没有挂起协程,那么协程将自动销毁。先记住这句话,在后面还会提到。

除此之外,Promise 还有一些其它责任:

  • return_void()/return_value()/yield_value() 方法: 用来控制 co_returnco_yield的行为;

  • unhandled_exception() 处理异常

  • 创建和销毁协程的 stackframe

  • 处理 stackframe 创建可能发生的异常

stackframe :函数运行时占用的内存空间,是栈上的数据集合,它包括:

  • Local variables

  • Saved copies of registers modified by subprograms that could need restoration

  • Argument parameters

  • Return address

Awaitable

第二个概念是 AwaitableAwaitable 负责管理协程挂起时的行为。

一个 Awaitable 对象可以成为 co_await 调用的对象。Awaitable 拥有以下方法:

  • await_ready():是否要挂起,如果返回 true,那么 co_await 就不会挂起函数;

  • await_resume()co_await 的返回值,通常返回空;

  • await_suspend():协程挂起时的行为;

可以在 await_suspend 中实现 await_ready 的效果,例如直接不挂起当前的协程,但在调用 await_suspend 之前,编译器必须将所有状态捆绑到协程的 stackframe 中,这会更耗时。

有时候我们的协程并不需要自定义复杂的行为,C++ 提供了两个默认的 Awaitable

suspend_always::await_ready() 总是返回 false,而 suspend_always::await_ready() 总是返回 true。其他的方法都是空的,没有任何作用。

如果没有其它多余的行为,我们可以在函数中直接调用 co_await std::suspend_always{} 来挂起一个函数。

Coroutine Handle

co_await 挂起函数,并创建了一个可调用对象,这个对象可以用来恢复Hanns乎的执行。这个可调用对象的类型就是 std::coroutine_handle<>,最常用的两个方法是:

  • handle.resume():恢复协程的执行;

  • handle.destroy():销毁协程;

Coroutine Handle 很像指针,我们可以复制它,但析构函数不会释放相关状态的内存。为了避免内存泄漏,一般要调用 handle.destroy() 来释放(尽管在某些情况下,协程会在完成后自行销毁——前文有提到)。同样像指针一样,一旦销毁了一个 Coroutine Handle ,指向同一个协程的另一个 Coroutine Handle 将指向垃圾,并在调用时表现出未定义行为。

学习更复杂的用法之前,我们先看下示例。

示例

这个简短的示例展示了 C++ 实现协程 "Hello world" 程序。我们执行完 "Hello " 后挂起函数,又在执行 handle.resume() 后恢复函数的运行。

非常简单,不再过多解释。

co_yield

C++ 协程与一个 Promise 交互之所以如此笨拙,有一个特殊原因就是为了 co_yield

如果 promise 是当前协程的 Promise 对象,那么执行:

co_yield <expression>;

相当于执行了:

co_await promise.yield_value(<expression>);

所以,需要在 promise_type 中添加一个 yield_value 方法。上面的例子可以改为:

可以用 co_yield 实现 Python 中的生成器,参考:https://lewissbaker.github.io/2018/09/05/understanding-the-promise-type

co_return

执行 co_return 语句时:

co_return <expression>;

相当于执行了:

co_return promise.return_value(<expression>); goto end;

下面再给出示例加上 co_return 的版本:

复杂一些

到此, AwaitableCoroutine Handle 好像还没有发挥什么作用,我写的示例程序都非常简单。

如果我们想在协程挂起的时候,做更多的动作,一般将 Coroutine Handle 传到 Awaitable 的 await_suspend() 中,用一个官网的例子展示一下:

小结

本文简单介绍了 C++ 协程,希望下次你写 C++ 协程的时候,首先想到这三个东西:

我本人也不是编程语言专家,对于 C++ 协程总觉得有些繁琐、怪异,或许是我并不清楚 C++ 在原有情况下支持协程的困难,但我依然觉得 C++ 团队可以做得更好。

我还需要花时间弄明白到底该如何在项目中使用这臃肿的协程。

不过,可以预见到的是,我们会在越来越多的 C++ 项目中看到协程的身影。比如 facebook folly 就已经实现了一个实验阶段的协程框架: https://github.com/facebook/folly/tree/master/folly/experimental/coro

也许等我再研究一段时间,会写一篇到底该如何使用 C++ 协程。

Reference

  • C++ Coroutine definitions: http://eel.is/c++draft/dcl.fct.def.coroutine#5

  • C++ draft expr.await: http://eel.is/c++draft/expr.await

  • C++ Coroutines: Understanding the promise type: https://lewissbaker.github.io/2018/09/05/understanding-the-promise-type

  • 官网的例子:
    https://en.cppreference.com/w/cpp/language/coroutines

  • My tutorial and take on C++20 coroutines:https://www.scs.stanford.edu/~dm/blog/c++-coroutines.html#coroutine-handles

参考阅读


  • 领域驱动设计(DDD)在爱奇艺打赏业务的实践

  • Redis 日志篇:无畏宕机实现高可用的杀手锏

  • 喜马拉雅自研网关架构演进过程

  • 如何从0到1构建稳定、高性能Redis集群?

  • 白话高并发中的协程


技术原创及架构实践文章,欢迎通过公众号菜单「联系我们」进行投稿。


高可用架构
改变互联网的构建方式

相关推荐

Java面试题合集200道!

1.Java中操作字符串都有哪些类?它们之间有什么区别?String、StringBuffer、StringBuilder.String和StringBufer、StringBuilder的区别...

JAVA分布式锁的原理,及多种分布式实现优劣对比分析

引题比如在同一个节点上,两个线程并发的操作A的账户,都是取钱,如果不加锁,A的账户可能会出现负数,正确的方式是对账户acount进行加锁,即使用synchronized关键字,对其进行加锁后,当有线程...

百度Linux C++后台开发面试题(个人整理)

1、C/C++程序的内存分区其实C和C++的内存分区还是有一定区别的,但此处不作区分:1)、栈区(stack)—由编译器自动分配释放,存放函数的参数值,局部变量的值等。其操作方式类似于数据结构中...

什么是云计算?看这篇就够了(建议收藏)

一、什么是云?云,又称云端,指无数的大型机房或者大型数据中心。二、为什么需要云?1)从用户的角度来讲:传统应用的需求日益复杂,比如需要支持更多的用户,需要更强的计算能力等,为满足这些日益增长的需求,企...

写PHP框架需要具备那些知识?

如果没用过框架,讨论各个框架的内容都没有可讨论性,想自己写个框架涉及到的内容很多,个人觉得自己写一个框架对自己的逻辑思维,开发架构以及这门语言都有质的提升。可以参照其他框架的源代码,仅仅是看他们的思路...

不允许还有Java程序员不了解BlockingQueue阻塞队列的实现原理

我们平时开发中好像很少使用到BlockingQueue(阻塞队列),比如我们想要存储一组数据的时候会使用ArrayList,想要存储键值对数据会使用HashMap,在什么场景下需要用到Blocking...

Java性能优化指南—缓存那些事

由于笔者自身水平有限,如果有不对或者任何建议欢迎批评和指正本文预计阅读时间10分钟,分为前言、填坑两部分,主要包含缓存的基本使用到高级应用场景的介绍一、前言在处理高并发请求时,缓存几乎是无往不利的利器...

卓象科技:Nosql的介绍以及和关系型数据库的区别

Nosql介绍NoSQL(NotOnlySQL),泛指非关系型数据库。Nosql的全称是NotOnlySql,这个概念很早就有人提出,在09年的时候比较火。Nosql指的是非关系型数...

腾讯一面凉经(一面竟然就问了2小时,什么情况?)

这次一面感觉是在打心理战,哥们自己的心里防线基本是被击溃,面到怀疑人生的程度,所以过程感觉不是太好,很多题哥们自己也感觉没答好,要么答得“缺胳膊少腿”,要么就是“画蛇添足”。先是聊项目,从项目的架构设...

我凭借这份pdf,最终拿到了阿里,腾讯,京东等八家大厂offer

怎样才能拿到大厂的offer,没有掌握绝对的技术,那么就要不断的学习我是如何笑对金九银十,拿到阿里,腾讯等八家大厂的offer的呢,今天分享我的秘密武器,美团大神整理的Java核心知识点,面试时面试官...

高并发 异步解耦利器:RocketMQ究竟强在哪里?

本文带大家从以下几个方面详细了解RocketMQ:RocketMQ如何保证消息存储的可靠性?RocketMQ如何保证消息队列服务的高可用?如何构建一个高可用的RocketMQ双主双从最小集群?Rock...

阿里最新Java架构师成长笔记开源

下面先给大家上一个总的目录大纲,基础的东西就不进行过多的赘述,我们将会从JVM说起,同时由于每篇的内容过多,我们也只说重点,太过基础的内容谁都会,我就不多敲字浪费大家的时间了!JVM多线程与高并发Sp...

程序员失业2个月找不到工作,狂刷了5遍这份pdf终获字节跳动offer

写在前面1月初失业,找了近2个多月的工作了,还没找到心仪的工作,感觉心好慌,不知道该怎么办了?找不到工作的时候压力很大,有人说自信会很受打击,还有人说会很绝望,是人生的低谷……尽管很多时候我们自己知道...

Spring AI 模块架构与功能解析

SpringAI是Spring生态系统中的一个新兴模块,专注于简化人工智能和机器学习技术在Spring应用程序中的集成。本文将详细介绍SpringAI的核心组件、功能模块及其之间的关...

Nginx从入门到精通,超详细整理,含项目实战案例|运维必学

Nginx是免费的、开源的、高性能的HTTP和反向代理服务器、邮件代理服务器、以及TCP/UDP代理服务器。因为它的稳定性、丰富的模块库、灵活的配置和低系统资源的消耗而闻名。Nginx可以做静态HT...

取消回复欢迎 发表评论: