如何使用C++ co_await处理并发任务 - 问答

在 C++ 中，co_await 是一个关键字，用于处理协程（coroutines）中的挂起点

首先，确保你的编译器支持 C++20 标准。然后，创建一个简单的异步任务，例如从网站下载数据。为此，我们将使用 std::future 和 std::async。接下来，使用 co_await 等待这些任务完成。

以下是一个示例：

#include<iostream>
#include<chrono>
#include<thread>
#include <future>
#include<vector>

// 模拟从网站下载数据的函数
std::string download_data(int id) {
    std::this_thread::sleep_for(std::chrono::seconds(1)); // 模拟耗时操作
    return "Data from website " + std::to_string(id);
}

// 使用 std::async 创建异步任务
std::future<std::string> async_download_data(int id) {
    return std::async(std::launch::async, download_data, id);
}

// 使用 C++20 协程处理并发任务
std::string handle_tasks() {
    std::vector<std::future<std::string>> tasks;

    for (int i = 0; i < 5; ++i) {
        tasks.push_back(async_download_data(i));
    }

    std::string result;
    for (auto& task : tasks) {
        result += co_await task;
    }

    co_return result;
}

int main() {
    auto coro_handle = handle_tasks();
    std::cout << "Waiting for tasks to complete..."<< std::endl;
    std::cout << "Result: "<< coro_handle.get()<< std::endl;

    return 0;
}

在这个示例中，我们首先创建了一个名为 download_data 的函数，该函数模拟从网站下载数据。接着，我们创建了一个名为 async_download_data 的函数，该函数使用 std::async 创建异步任务。最后，我们创建了一个名为 handle_tasks 的协程函数，该函数使用 co_await 等待所有任务完成，并将结果拼接在一起。

请注意，要使用 C++20 协程，需要在编译命令中添加 -std=c++20 -fcoroutines 参数。例如，对于 g++ 编译器，可以使用以下命令：

g++ -std=c++20 -fcoroutines example.cpp -o example

这样，你就可以使用 C++20 的 co_await 关键字处理并发任务了。

0 赞

0 踩