如何正確使用c++ condition

c++
小樊
94
2024-07-24 13:33:13

C++中的條件變量（condition variable）是一種線程同步機(jī)制，用于在多線程編程中控制線程的執(zhí)行順序和通信。正確使用條件變量需要遵循以下步驟：

  1. 創(chuàng)建條件變量對(duì)象：使用std::condition_variable類創(chuàng)建條件變量對(duì)象。

  2. 創(chuàng)建互斥量對(duì)象：使用std::mutex類創(chuàng)建互斥量對(duì)象，用于保護(hù)共享數(shù)據(jù)。

  3. 在需要等待某個(gè)條件的線程中，通過(guò)std::unique_lockstd::mutex對(duì)象鎖住互斥量。

  4. 調(diào)用std::condition_variable的wait()方法等待條件的發(fā)生，同時(shí)釋放互斥量，使得其他線程可以訪問(wèn)共享數(shù)據(jù)。

  5. 在滿足條件時(shí)，通過(guò)notify_one()或notify_all()方法通知等待的線程。

以下是一個(gè)簡(jiǎn)單的示例代碼：

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

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

void worker_thread()
{
    std::unique_lock<std::mutex> lck(mtx);
    cv.wait(lck, [] { return ready; });
    std::cout << "Worker thread is processing data" << std::endl;
}

int main()
{
    std::thread worker(worker_thread);

    {
        std::lock_guard<std::mutex> lck(mtx);
        ready = true;
    }

    cv.notify_one();

    worker.join();

    return 0;
}

在上述示例中，worker_thread函數(shù)通過(guò)條件變量cv等待ready變量為true，主線程在修改ready后通過(guò)notify_one()通知worker_thread線程。

0 踩