在C++中,notify_all
是一個用于喚醒所有等待中的線程的方法,通常與互斥鎖(mutex)和條件變量(condition variable)一起使用。這個方法可以用于線程間的通信和同步。
以下是一個簡單的示例,演示了如何在C++中使用notify_all
:
#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 working..." << std::endl;
}
int main() {
std::thread t(worker_thread);
// 做一些準備工作
std::this_thread::sleep_for(std::chrono::seconds(2));
{
std::lock_guard<std::mutex> lck(mtx);
ready = true;
}
// 喚醒線程
cv.notify_all();
t.join();
return 0;
}
在這個示例中,worker_thread
函數等待ready
變量為true
,一旦接收到notify_all
通知,就會開始執行操作。在main
函數中,我們先讓線程休眠2秒,然后設置ready
為true
并調用notify_all
通知線程。
需要注意的是,在調用notify_all
前,必須先獲取互斥鎖,以確保線程安全。另外,條件變量的等待通知通常使用lambda函數來定義等待的條件。
notify_all
方法用于喚醒所有等待中的線程,如果只想喚醒一個線程,可以使用notify_one
方法。
希望這個簡單的入門指南能幫助你理解如何在C++中使用notify_all
方法。祝學習順利!