阅读量:0
C++中的条件变量(condition variable)是一种线程同步机制,用于在多线程编程中控制线程的执行顺序和通信。正确使用条件变量需要遵循以下步骤:
创建条件变量对象:使用std::condition_variable类创建条件变量对象。
创建互斥量对象:使用std::mutex类创建互斥量对象,用于保护共享数据。
在需要等待某个条件的线程中,通过std::unique_lockstd::mutex对象锁住互斥量。
调用std::condition_variable的wait()方法等待条件的发生,同时释放互斥量,使得其他线程可以访问共享数据。
在满足条件时,通过notify_one()或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 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函数通过条件变量cv等待ready变量为true,主线程在修改ready后通过notify_one()通知worker_thread线程。