亚洲激情专区-91九色丨porny丨老师-久久久久久久女国产乱让韩-国产精品午夜小视频观看

溫馨提示×

c++ coroutine如何實現任務調度

c++
小樊
81
2024-11-23 12:18:22
欄目: 編程語言

C++20 引入了協程(coroutines),使得異步編程變得更加簡單和直觀。要實現任務調度,我們可以使用 std::futurestd::promise 來在協程之間傳遞數據,以及使用 std::jthreadstd::thread 來執行協程。

以下是一個簡單的任務調度示例,展示了如何使用 C++20 協程實現任務調度:

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

// 定義一個協程任務
std::future<void> asyncTask(int taskId) {
    std::cout << "Task " << taskId << " started." << std::endl;
    std::this_thread::sleep_for(std::chrono::seconds(1)); // 模擬耗時操作
    std::cout << "Task " << taskId << " completed." << std::endl;
    return std::async(std::launch::deferred, []() {}); // 返回一個 future 對象
}

// 任務調度器
class TaskScheduler {
public:
    void addTask(int taskId) {
        tasks.emplace_back([taskId]() { asyncTask(taskId); });
    }

    void run() {
        std::vector<std::jthread> threads;
        for (auto& task : tasks) {
            threads.emplace_back([&task]() { task(); });
        }

        for (auto& thread : threads) {
            thread.join();
        }
    }

private:
    std::vector<std::function<void()>> tasks;
};

int main() {
    TaskScheduler scheduler;
    scheduler.addTask(1);
    scheduler.addTask(2);
    scheduler.addTask(3);

    scheduler.run();

    return 0;
}

在這個示例中,我們創建了一個 TaskScheduler 類,用于添加和管理任務。addTask 方法接受一個任務 ID,并將其添加到任務列表中。run 方法創建一個線程池,并為每個任務分配一個線程來執行。當所有任務完成后,主線程將等待所有子線程完成。

請注意,這個示例使用了 std::jthread,它是 C++20 中用于處理協程的線程類。std::jthread 在析構時會自動加入(join)線程,因此我們不需要顯式調用 join 方法。如果你使用的是 std::thread,則需要在每個線程完成時調用 join 方法,以避免程序提前退出。

0
墨竹工卡县| 浦城县| 酒泉市| 靖江市| 吉水县| 古交市| 格尔木市| 陆川县| 洪湖市| 资讯| 盐源县| 怀宁县| 宁河县| 南阳市| 西昌市| 垣曲县| 星子县| 江油市| 织金县| 曲水县| 佛学| 阳原县| 新昌县| 牡丹江市| 喜德县| 巴中市| 资源县| 沂源县| 嫩江县| 双辽市| 固原市| 甘泉县| 安阳市| 阜阳市| 和政县| 宜州市| 上饶县| 湾仔区| 从化市| 阿瓦提县| 龙里县|