condition_variable的例子代码
时间: 2024-01-04 09:13:37 浏览: 78
好的,以下是一个使用condition_variable的例子代码:
```
#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
std::mutex mtx;
std::condition_variable cv;
bool ready = false;
void print_id(int id) {
std::unique_lock<std::mutex> lck(mtx);
while (!ready) {
cv.wait(lck);
}
std::cout << "thread " << id << std::endl;
}
void go() {
std::unique_lock<std::mutex> lck(mtx);
ready = true;
cv.notify_all();
}
int main() {
std::thread threads[10];
for (int i = 0; i < 10; ++i) {
threads[i] = std::thread(print_id, i+1);
}
std::cout << "10 threads ready to race..." << std::endl;
go();
for (auto& th : threads) {
th.join();
}
return 0;
}
```
这个例子中,有10个线程准备执行任务。主线程通过调用go()函数来通知这10个线程开始执行任务。而在这10个线程中,我们使用condition_variable和互斥锁来等待主线程的通知,并在收到通知后执行任务,从而避免了不必要的忙等待。
阅读全文