阅读量:0
在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
方法。祝学习顺利!