91超碰碰碰碰久久久久久综合_超碰av人澡人澡人澡人澡人掠_国产黄大片在线观看画质优化_txt小说免费全本

溫馨提示×

如何在C++線程類中實現任務分配

c++
小樊
88
2024-08-29 22:47:42
欄目: 編程語言

在 C++ 中,可以使用` 庫來創建線程并分配任務

#include<iostream>
#include<vector>
#include<thread>
#include <mutex>

class Task {
public:
    virtual void execute() = 0;
};

class PrintTask : public Task {
public:
    PrintTask(const std::string& message) : message_(message) {}

    void execute() override {
        std::cout << "Thread "<< std::this_thread::get_id() << ": "<< message_<< std::endl;
    }

private:
    std::string message_;
};

class ThreadPool {
public:
    ThreadPool(size_t num_threads) {
        for (size_t i = 0; i < num_threads; ++i) {
            threads_.emplace_back(&ThreadPool::worker, this);
        }
    }

    ~ThreadPool() {
        {
            std::unique_lock<std::mutex> lock(queue_mutex_);
            stop_ = true;
        }
        condition_.notify_all();
        for (auto& thread : threads_) {
            thread.join();
        }
    }

    void add_task(Task* task) {
        std::unique_lock<std::mutex> lock(queue_mutex_);
        tasks_.push(task);
        condition_.notify_one();
    }

private:
    void worker() {
        while (true) {
            Task* task = nullptr;
            {
                std::unique_lock<std::mutex> lock(queue_mutex_);
                condition_.wait(lock, [this] { return !tasks_.empty() || stop_; });
                if (stop_) {
                    break;
                }
                task = tasks_.front();
                tasks_.pop();
            }
            task->execute();
        }
    }

    std::vector<std::thread> threads_;
    std::queue<Task*> tasks_;
    std::mutex queue_mutex_;
    std::condition_variable condition_;
    bool stop_ = false;
};

int main() {
    ThreadPool pool(4); // 創建一個包含 4 個線程的線程池

    // 添加任務到線程池
    for (int i = 0; i < 10; ++i) {
        pool.add_task(new PrintTask("Hello from task " + std::to_string(i)));
    }

    // 等待所有任務完成
    // 注意:這里沒有刪除任務對象,實際應用中需要考慮內存管理
    std::this_thread::sleep_for(std::chrono::seconds(2));

    return 0;
}

這個示例中,我們定義了一個 Task 基類和一個派生自 TaskPrintTask 類。ThreadPool 類負責管理線程和任務隊列。add_task 方法用于向線程池添加新任務。線程池中的每個線程都會從任務隊列中獲取任務并執行它。

請注意,這個示例沒有處理任務對象的內存管理。在實際應用中,你需要考慮如何安全地刪除任務對象以避免內存泄漏。可以考慮使用智能指針(如 std::shared_ptrstd::unique_ptr)來管理任務對象的生命周期。

0
山阴县| 长岭县| 成都市| 萍乡市| 温泉县| 四会市| 阜新市| 渝中区| 淮安市| 当阳市| 尚义县| 祁阳县| 日喀则市| 临西县| 嵊泗县| 岑溪市| 静乐县| 罗源县| 平定县| 康保县| 崇文区| 阿克陶县| 雅江县| 永寿县| 平塘县| 常德市| 黄梅县| 卫辉市| 茶陵县| 太原市| 仲巴县| 高淳县| 大关县| 绥中县| 大埔县| 吉水县| 西乌| 台安县| 桃源县| 祁连县| 虎林市|