**题目：C++20中使用协程实现异步链式查询**

作者

在传统的C++编程中，处理异步操作往往需要回调函数或Future/Promise等机制，代码层级嵌套多、可读性差。C++20引入了协程（Coroutines）语法，提供了更直观、更像同步代码的异步实现方式。本文将以“链式数据库查询”为例，演示如何使用C++20协程完成多步异步查询，并保证代码的可维护性与可读性。

1. 协程基础回顾

template<typename T>
struct Task {
    struct promise_type {
        T result_;
        Task get_return_object() { return Task{std::coroutine_handle <promise_type>::from_promise(*this)}; }
        std::suspend_always initial_suspend() noexcept { return {}; }
        std::suspend_always final_suspend() noexcept { return {}; }
        void unhandled_exception() { std::terminate(); }
        void return_value(T val) { result_ = std::move(val); }
    };
    std::coroutine_handle <promise_type> handle_;
    Task(std::coroutine_handle <promise_type> h) : handle_(h) {}
    ~Task() { if (handle_) handle_.destroy(); }
    T get() { handle_.resume(); return handle_.promise().result_; }
};

上述简易Task封装允许我们使用co_await与co_return进行协程编写。

2. 异步数据库访问接口

我们假设有一个简化的异步查询API：

Task<std::string> async_query(const std::string& sql);

async_query执行SQL查询并在完成后返回结果字符串。内部实现可以是网络I/O、磁盘读写等非阻塞操作，关键点是返回一个Task，而不是立即得到结果。

3. 链式查询实现

假设业务流程如下：

  1. 根据用户ID查询用户基本信息。
  2. 根据用户ID查询用户最近的订单列表。
  3. 根据订单ID查询订单详情。
  4. 计算总消费金额并返回。

我们用协程实现：

Task <double> compute_total_spend(int user_id) {
    // 步骤1：查询用户信息
    std::string user_info_sql = "SELECT * FROM users WHERE id = " + std::to_string(user_id);
    std::string user_info = co_await async_query(user_info_sql);

    // 步骤2：查询订单列表
    std::string orders_sql = "SELECT id FROM orders WHERE user_id = " + std::to_string(user_id);
    std::string orders_raw = co_await async_query(orders_sql);
    std::vector <int> order_ids = parse_order_ids(orders_raw); // 解析函数自定义

    double total = 0.0;
    // 步骤3：对每个订单并行查询详情
    std::vector<Task<double>> detail_tasks;
    for (int oid : order_ids) {
        detail_tasks.emplace_back(async_order_detail(oid));
    }
    for (auto &t : detail_tasks) {
        double amount = co_await t; // 协程等待完成
        total += amount;
    }
    co_return total;
}

注意：

  • co_await 会挂起当前协程，直到被await的Task完成。
  • 通过把所有订单详情查询打包为Task列表，并逐一co_await，可以实现并发执行。

4. 运行与错误处理

主线程调用：

int main() {
    try {
        double total = compute_total_spend(42).get(); // 调用get()获取结果
        std::cout << "Total spend: " << total << std::endl;
    } catch (const std::exception &e) {
        std::cerr << "Error: " << e.what() << std::endl;
    }
    return 0;
}

错误处理可以通过协程内部抛异常，然后在调用方捕获。若要在协程内部统一处理，可在promise_type::unhandled_exception()中记录日志或重试逻辑。

5. 性能与实践建议

  1. 协程枢纽：使用一个专门的I/O循环（如asio的io_context）来调度协程，避免频繁创建线程。
  2. 任务复用：如果查询语句相同或仅参数变化，使用Task缓存可以减少编译与运行开销。
  3. 异常安全：在promise_type中实现return_void或return_value时，保证异常能够及时返回。
  4. 可读性：与传统回调相比，协程让异步流程像同步代码，逻辑更清晰。

6. 小结

C++20协程为异步编程提供了更高层次的抽象，让链式异步查询变得直观、易于维护。通过简易的Task包装器、co_await与co_return，可以轻松实现并发执行、错误处理与结果聚合。随着标准库与第三方库对协程支持的完善，未来的C++异步编程将更加简洁、高效。

发表评论