在 C++20 标准中,协程(Coroutines)被正式纳入语言核心,为异步编程提供了极大的便利。相比传统的回调或基于事件循环的实现,协程可以让代码更直观、易读、易维护。本文将从协程的基本概念入手,逐步讲解其实际应用场景,并给出几个实用的最佳实践,帮助你在项目中快速上手并充分发挥协程的优势。
1. 协程概述
协程是一种可暂停和恢复的函数体,它可以在执行过程中“挂起”,将当前状态保存下来,然后在未来某个时刻继续执行。协程的核心是 promise(承诺)和 generator(生成器):
- promise:定义协程的返回值、异常处理、挂起点行为等;
- generator:由协程函数返回的可迭代对象,支持
co_yield、co_return等关键字。
C++20 将协程抽象为三大概念:
- awaiter:表示可以等待的对象,定义
await_ready、await_suspend、await_resume三个成员函数; - promise_type:协程的承诺对象,提供
get_return_object、initial_suspend、final_suspend、unhandled_exception等成员; - coroutine_handle:协程句柄,用于挂起、恢复、销毁协程。
2. 协程的典型使用场景
| 场景 | 传统实现 | 协程实现 |
|---|---|---|
| 异步 I/O | std::future + std::async 或 boost::asio 回调 |
co_await 读取 / 写入 |
| 生成器 | 手动维护迭代器 | co_yield 自动生成 |
| 事件循环 | while (true) { poll(); } |
for (auto &item : async_queue) { co_await item; } |
| 协程式协程 | 嵌套回调(Callback Hell) | co_await 组合 |
3. 示例:使用协程实现一个异步 HTTP 客户端
下面给出一个简化的异步 HTTP GET 示例,演示如何使用 co_await 与网络库(假设使用 cppcoro 或 asio 的协程扩展)完成请求与响应的流程。
#include <asio.hpp>
#include <iostream>
#include <string>
using asio::ip::tcp;
// 简单的协程式 TCP 连接
asio::awaitable<std::string> fetch(const std::string &host, const std::string &path) {
auto executor = co_await asio::this_coro::executor;
tcp::resolver resolver(executor);
auto endpoints = co_await resolver.async_resolve(host, "http", asio::use_awaitable);
tcp::socket socket(executor);
co_await asio::async_connect(socket, endpoints, asio::use_awaitable);
// 发送请求
std::string request = "GET " + path + " HTTP/1.1\r\n"
"Host: " + host + "\r\n"
"Connection: close\r\n\r\n";
co_await asio::async_write(socket, asio::buffer(request), asio::use_awaitable);
// 读取响应
asio::streambuf response;
co_await asio::async_read_until(socket, response, "\r\n", asio::use_awaitable);
std::istream response_stream(&response);
std::string status_line;
std::getline(response_stream, status_line);
if (!response_stream || status_line.substr(0, 9) != "HTTP/1.1") {
co_return "Invalid response";
}
// 读取到正文
std::string body;
std::ostringstream oss;
oss << response_stream.rdbuf();
body = oss.str();
co_return body;
}
int main() {
asio::io_context ctx;
auto fut = fetch("example.com", "/");
fut
.then([](std::string body) {
std::cout << "Response body:\n" << body << '\n';
})
.wait();
return 0;
}
关键点解析
co_await用于等待异步操作完成,代码保持同步式结构;- `asio::awaitable ` 表示返回值类型为 `T` 的协程;
use_awaitable标记为协程上下文使用,触发协程编译器的代码生成。
4. 协程最佳实践
-
避免过度嵌套
协程可以嵌套使用,但深层嵌套会导致大量栈帧保存,影响性能。尽量把协程拆成独立函数,使用co_await链接。 -
错误处理
协程中使用co_await时,如果异常被抛出,协程会被取消。建议在协程入口处捕获异常并通过promise_type::unhandled_exception统一处理。 -
资源管理
由于协程可能在挂起期间存在,所有资源应使用 RAII 或co_await的asio::use_awaitable管理,防止悬挂指针。 -
性能监测
通过std::chrono或 profiler 监测协程切换次数与耗时。若切换频繁,可考虑将小协程合并或使用更粗粒度的任务。 -
兼容旧代码
若项目中已有大量基于回调或std::future的异步代码,可逐步用协程包装旧接口。例如,写一个async_wrap函数将std::future转换为awaitable.
5. 小结
C++20 协程为高性能异步编程提供了更为优雅的语义。通过 co_await 与标准库、第三方库(如 asio、cppcoro)的配合,能够显著提升代码可读性与维护性。关键在于合理拆分协程粒度、统一错误处理以及资源管理。希望本文的示例与实践建议能帮助你在项目中快速上手并发挥协程的最大价值。