C++如何实现一个简单的基于协程的异步数据库查询-C++-PHP中文网

c++协程需c++20及对应编译选项（g++/clang++/msvc各不同），标准库支持、awaitable驱动封装、io调度、异常与连接生命周期管理缺一不可。

c++如何实现一个简单的基于协程的异步数据库查询

协程支持需要 C++20 且编译器得开对选项

不是所有 C++20 编译器默认启用协程，g++ 需要 -std=c++20 -fcoroutines，clang++ 要加 -std=c++20 -fcoroutines-ts（注意 TS 后缀）。MSVC 2019 16.11+ 支持，但需开启 /std:c++20 /await。漏掉任一标志，co_await 会报错：‘co_await’ is not allowed in a function that does not return a coroutine type。

别急着写 co_await，先确认你的 std::experimental::coroutine_handle 或更推荐的 std::coroutine_handle 能正常包含——如果 #include <coroutine></coroutine> 失败，说明标准库还没跟上编译器，得换工具链或降级用 libco/Boost.ASIO 的协程封装。

数据库驱动必须提供 awaitable 接口

原生 SQLite、MySQL C API 都不支持协程；你不能直接 co_await sqlite3_exec(...)。得自己包装或选支持 await 的驱动：

SQLite：用 sqlite3_async 扩展 + 线程池 + std::suspend_always 自定义 awaiter
PostgreSQL：libpqxx 5.4+ 提供 connection::exec_params_async，返回 awaitable<:vector>></:vector>
通用方案：用 asio::thread_pool 包一层阻塞调用，返回自定义 awaitable 类型

重点不是“怎么查”，而是“谁来调度 IO”。协程本身不解决阻塞，它只是把回调逻辑扁平化——底层仍需异步 IO 或线程卸载。没这层，协程只是语法糖，还拖慢性能。

手写一个最小可用 awaitable 封装

假设你用线程池执行 MySQL 查询，目标是让 co_await db_query("SELECT id FROM users") 返回 std::vector<:string></:string>：

C++14

C++14 对 C++11 的修正与增强版本，适合旧系统维护和较老工具链兼容。

下载

struct db_awaitable {
  std::string sql;
  asio::thread_pool& pool;

  bool await_ready() { return false; }
  void await_suspend(std::coroutine_handle h) {
    asio::post(pool, [h, sql = std::move(sql)]() mutable {
      auto rows = blocking_mysql_query(sql); // 真实阻塞调用
      struct result_t { std::vector<:string> data; };
      h.resume(); // 注意：这里没传值，需靠成员变量或外部存储
    });
  }
  std::vector<:string> await_resume() {
    return last_result; // 必须线程安全，或改用 promise/future 搭配
  }
  static thread_local std::vector<:string> last_result;
};</:string></:string></:string>

问题来了：await_resume() 无法直接接收异步结果。更稳妥做法是搭配 std::promise 和 std::future，或者用 asio::awaitable<t></t>（需 ASIO 1.22+）——否则容易出现数据竞争或悬垂引用。