如何使用条件变量实现线程同步?
时间: 2024-06-15 07:07:07 浏览: 109
使用条件变量实现线程同步的步骤如下:
1. 创建条件变量和互斥锁:首先,需要创建一个条件变量和一个互斥锁。条件变量用于线程之间的通信,互斥锁用于保护共享资源。
2. 加锁:在访问共享资源之前,需要先获取互斥锁,确保只有一个线程可以访问共享资源。
3. 检查条件:在访问共享资源之前,需要检查条件是否满足。如果条件不满足,则线程需要等待。
4. 等待条件:如果条件不满足,线程需要等待条件变量的通知。调用条件变量的等待函数,将线程置于等待状态,并释放互斥锁,允许其他线程访问共享资源。
5. 接收通知:当其他线程改变了共享资源,并满足了条件时,需要发送通知给等待的线程。调用条件变量的通知函数,唤醒一个或多个等待的线程。
6. 解锁:当接收到通知后,等待的线程被唤醒,需要重新获取互斥锁,并继续执行。
下面是一个使用条件变量实现线程同步的示例代码:
```c++
#include <iostream>
#include <thread>
#include <condition_variable>
std::mutex mtx;
std::condition_variable cv;
bool ready = false;
void worker_thread()
{
// 加锁
std::unique_lock<std::mutex> lock(mtx);
// 检查条件
while (!ready)
{
// 等待条件
cv.wait(lock);
}
// 条件满足,执行任务
std::cout << "Worker thread is working." << std::endl;
}
int main()
{
// 创建工作线程
std::thread worker(worker_thread);
// 做一些其他的工作...
// 准备好条件
{
std::lock_guard<std::mutex> lock(mtx);
ready = true;
}
// 发送通知
cv.notify_one();
// 等待工作线程完成
worker.join();
return 0;
}
```
阅读全文