在 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
關鍵字處理并發任務了。