C++條件變量能處理復(fù)雜邏輯嗎

c++
小樊
81
2024-11-09 07:16:36

是的，C++的條件變量（condition variable）可以處理復(fù)雜邏輯。條件變量是C++標(biāo)準(zhǔn)庫(kù)中的一個(gè)同步原語(yǔ)，它允許線程等待某個(gè)條件成立，同時(shí)釋放互斥鎖（mutex），讓其他線程繼續(xù)執(zhí)行。當(dāng)條件成立時(shí)，等待的線程會(huì)被喚醒并重新獲取互斥鎖。

在處理復(fù)雜邏輯時(shí)，可以使用條件變量與其他同步原語(yǔ)（如互斥鎖、信號(hào)量等）結(jié)合使用，以確保線程安全。以下是一個(gè)簡(jiǎn)單的示例，展示了如何使用條件變量處理復(fù)雜邏輯：

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>

std::mutex mtx;
std::condition_variable cv;
bool ready = false;

void print_id(int id) {
    std::unique_lock<std::mutex> lck(mtx);

    // 等待條件成立
    while (!ready) {
        cv.wait(lck);
    }

    // 條件成立，輸出線程ID
    std::cout << "Thread " << id << '\n';
}

void go() {
    std::this_thread::sleep_for(std::chrono::seconds(1));
    {
        std::lock_guard<std::mutex> lck(mtx);
        ready = true;
    }
    // 喚醒所有等待的線程
    cv.notify_all();
}

int main() {
    std::thread threads[10];
    // 創(chuàng)建10個(gè)線程
    for (int i = 0; i < 10; ++i)
        threads[i] = std::thread(print_id, i);

    std::thread t(go);
    t.join();

    for (auto &th : threads) th.join();

    return 0;
}

在這個(gè)示例中，我們創(chuàng)建了10個(gè)線程，它們都在等待一個(gè)條件（ready 變量）成立。主線程在1秒后設(shè)置條件成立，并喚醒所有等待的線程。這個(gè)例子展示了如何使用條件變量處理多個(gè)線程之間的同步和通信。當(dāng)然，你可以根據(jù)實(shí)際需求編寫(xiě)更復(fù)雜的邏輯。

0 踩