C++11条件变量wait函数浅析

设置了 Predicate时，只有当 pred 条件为 false 时调用 wait() 才会阻塞当前线程，并且在收到其他线程的通知后只有当 pred 为 true 时才会被解除阻塞

#include 
#include 
#include 
#include 
#include using namespace std;int a = 0;int main(){condition_variable cv;std::thread t([&](){while(true){this_thread::sleep_for(chrono::seconds(1));a++;cout << a <<endl;if(a == 5){cv.notify_all();}}});mutex mtx;std::unique_lock<std::mutex> lock(mtx);cv.wait(lock, [&](){return a > 10;});cout << "a = " << a << endl;return 0;
}

从运行结果我们看到，cv的条件a==5时进行了一次notify，然后此时条件不成立，主线程无法解除阻塞，也即下方代码的wait返回后检查while条件不成立，于是继续执行wait，释放锁，等待notify

当a>10后，条件成立了，由于此时无法得到子线程的notify，所以主线程会一直wait在cv上

template<typename _Predicate> void wait(unique_lock<mutex>& __lock, _Predicate __p) {while (!__p())wait(__lock);  // 释放锁，等待notify}
}

总结：

如果用户提供了_Predicate ，当用户调用wait时会检查_Predicate 是否成立

• 若成立，则不会释放锁阻塞，会继续向下执行
• 若不成立，则进入上述wait源码中的while循环，释放锁，等待notify

线程等待在wait上时，只有得到notify，抢到锁，才会起来检查条件是否成立，不成立继续释放锁，等待notify，成立则可以解除阻塞

注意： wait释放锁后，没得到notify，就算条件成立了，也无法解除阻塞

本文来自互联网用户投稿，文章观点仅代表作者本人，不代表本站立场，不承担相关法律责任。如若转载，请注明出处。 如若内容造成侵权/违法违规/事实不符，请点击【内容举报】进行投诉反馈！