随着 C++20 的发布，协程成为语言的一部分，为异步编程提供了更直观、类型安全且高效的手段。本文将从协程的基本概念、实现原理、关键类型、典型使用场景以及常见陷阱等方面进行系统阐述，帮助读者快速掌握 C++20 协程的核心技术。
一、协程到底是什么？
协程（Coroutine）是一种能够在执行过程中“暂停”并在之后恢复的计算单元。与传统的线程或进程相比，协程的切换成本更低，且不需要操作系统内核的调度。C++20 将协程作为语言级特性，引入了关键字 co_await、co_yield、co_return 和 co_spawn（通过库实现）来实现协程的编写。
二、协程的基本构成
co_await：挂起协程，等待一个awaitable对象完成。co_yield：生成一个值并挂起协程，类似生成器。co_return：返回协程最终结果并结束协程。co_spawn（或手动调用operator()）：启动协程。
协程函数的返回类型必须是 **`std::future
`**、**`std::generator`**、**`std::task`**（第三方库）等 `awaitable` 类型，或者是用户自定义满足协程协议的类型。 ### 例子：一个简单的协程 “`cpp #include #include struct SimpleTask { struct promise_type { SimpleTask get_return_object() { return {}; } std::suspend_never initial_suspend() { return {}; } std::suspend_never final_suspend() noexcept { return {}; } void return_void() {} void unhandled_exception() {} }; }; SimpleTask hello() { std::cout `、自定义 `Timer` | | `awaiter` | 包装 `awaitable` 的对象，提供 `await_ready`、`await_suspend`、`await_resume` | `std::future ::awaitable` | | `promise_type` | 协程的协作对象，管理协程的状态 | `std::future ::promise_type` | | `coroutine_handle` | 运行时的句柄，允许手动控制协程 | `std::coroutine_handle` | ### 1. `await_ready` 返回 `true` 表示可以继续执行；返回 `false` 则挂起协程。 ### 2. `await_suspend` 挂起协程时调用。可以选择在此处将协程句柄插入事件循环或线程池。 ### 3. `await_resume` 协程恢复后调用，返回协程的结果。 ## 四、协程的实现原理 协程的实现与 **协程框架** 或 **事件循环** 结合。协程本质上是一个 **状态机**，`await_suspend` 会把协程句柄挂入某个队列，等到 `await_ready` 成立后再次激活。常见实现方式： – **Fiber**：在单线程中通过上下文切换实现协程。 – **异步 IO**：如 `boost::asio::awaitable`，通过 IO 完成回调来恢复协程。 – **线程池**：将协程挂起后把句柄放入线程池任务队列。 ## 五、典型使用场景 | 场景 | 解决方案 | 关键点 | |——|———-|——–| | **异步文件 IO** | `asio::async_read` + `co_await` | 结合事件循环 | | **网络服务器** | `co_spawn` + `co_await` | 事件驱动、回调链 | | **生成器** | `co_yield` | `std::generator ` | | **并发控制** | `std::atomic` + `co_await` | 线程安全 | | **定时任务** | 自定义 `Timer` + `co_await` | 事件循环 | ### 示例：异步 HTTP 客户端 “`cpp #include #include #include using tcp = boost::asio::ip::tcp; namespace http = boost::beast::http; boost::asio::awaitable fetch(tcp::resolver::results_type endpoints) { auto socket = co_await boost::asio::make_socket(tcp::socket); co_await boost::asio::async_connect(socket, endpoints, boost::asio::use_awaitable); http::request req{http::verb::get, “/”, 11}; req.set(http::field::host, “example.com”); req.set(http::field::user_agent, “Boost.Beast”); co_await http::async_write(socket, req, boost::asio::use_awaitable); boost::beast::flat_buffer buffer; http::response res; co_await http::async_read(socket, buffer, res, boost::asio::use_awaitable); std::cout