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

avatar
作者
筋斗云
阅读量:0

在 C++ 中,co_await 是一个关键字,用于处理协程(coroutines)中的挂起点

首先,确保你的编译器支持 C++20 标准。然后,创建一个简单的异步任务,例如从网站下载数据。为此,我们将使用 std::futurestd::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 关键字处理并发任务了。

广告一刻

为您即时展示最新活动产品广告消息,让您随时掌握产品活动新动态!