溫馨提示×

如何使用C++ co_await處理并發(fā)任務(wù)

c++
小樊
88
2024-09-10 19:09:30
欄目: 編程語言

在 C++ 中，co_await 是一個關(guān)鍵字，用于處理協(xié)程（coroutines）中的掛起點

首先，確保你的編譯器支持 C++20 標(biāo)準(zhǔn)。然后，創(chuàng)建一個簡單的異步任務(wù)，例如從網(wǎng)站下載數(shù)據(jù)。為此，我們將使用 std::future 和 std::async。接下來，使用 co_await 等待這些任務(wù)完成。

以下是一個示例：

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

// 模擬從網(wǎng)站下載數(shù)據(jù)的函數(shù)
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 創(chuàng)建異步任務(wù)
std::future<std::string> async_download_data(int id) {
    return std::async(std::launch::async, download_data, id);
}

// 使用 C++20 協(xié)程處理并發(fā)任務(wù)
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;
}

在這個示例中，我們首先創(chuàng)建了一個名為 download_data 的函數(shù)，該函數(shù)模擬從網(wǎng)站下載數(shù)據(jù)。接著，我們創(chuàng)建了一個名為 async_download_data 的函數(shù)，該函數(shù)使用 std::async 創(chuàng)建異步任務(wù)。最后，我們創(chuàng)建了一個名為 handle_tasks 的協(xié)程函數(shù)，該函數(shù)使用 co_await 等待所有任務(wù)完成，并將結(jié)果拼接在一起。

請注意，要使用 C++20 協(xié)程，需要在編譯命令中添加 -std=c++20 -fcoroutines 參數(shù)。例如，對于 g++ 編譯器，可以使用以下命令：

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

這樣，你就可以使用 C++20 的 co_await 關(guān)鍵字處理并發(fā)任務(wù)了。

0 踩