线程 condition_variable

Posted 于光远

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了线程 condition_variable相关的知识,希望对你有一定的参考价值。

http://www.cnblogs.com/haippy/p/3252041.html

理解wait();当前线程调用 wait() 后将被阻塞(此时当前线程应该获得了锁(mutex)。在线程被阻塞时,该函数会自动调用 lck.unlock() 释放锁,使得其他被阻塞在锁竞争上的线程得以继续执行。另外,一旦当前线程获得通知(notified,通常是另外某个线程调用 notify_* 唤醒了当前线程),wait()函数也是自动调用 lck.lock(),使得lck的状态和 wait 函数被调用时相同

void wait (unique_lock& lck, Predicate pred);

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

因此第二种情况类似以下代码:

while (!pred()) wait(lck);
#include <iostream>                // std::cout
#include <thread>                // std::thread, std::this_thread::yield
#include <mutex>                // std::mutex, std::unique_lock  
#include <condition_variable>    // std::condition_variable
#include <chrono>             // std::chrono::seconds


std::mutex mtx; std::condition_variable cv;
std::unique_lock <std::mutex> lck(mtx);
while (cv.wait_for(lck,std::chrono::seconds(1)) == std::cv_status::timeout) {
std::cout
<< \'.\'; std::cout.flush();
}
bool shipment_available()
{
  return cargo != 0;
}
cv.wait(lck, shipment_available);
cv.wait(lck);

 cv.notify_all();
 cv.notify_one();


http://www.tuicool.com/articles/222yY3

题目:子线程循环  10  次,接着主线程循环  100  次,接着又回到子线程循环  10 次,接着再回到主线程又循环  100  次,如此循环 50 次,试写出代码。注意:一定是子线程先执行,主线程再执行。

 

#include<iostream>  
#include<thread>  
#include<mutex>  
#include<condition_variable>  
using namespace std;
mutex m;
condition_variable cond;
int flag = 10;
void fun(int num){
    for (int i = 0; i<50; i++){
        unique_lock<mutex> lk(m);//A unique lock is an object that manages a mutex object with unique ownership in both states: locked and unlocked.  
        while (flag != num)
            cond.wait(lk);//在调用wait时会执行lk.unlock()  
        for (int j = 0; j<num; j++)
            cout << j << " ";
        cout << endl;
        flag = (num == 10) ? 100 : 10;
        cond.notify_one();//被阻塞的线程唤醒后lk.lock()恢复在调用wait前的状态  
    }
}
int main(){
    thread child(fun, 10);
    fun(100);
    child.join();
    return 0;
}

 

以上是关于线程 condition_variable的主要内容,如果未能解决你的问题,请参考以下文章

C++11多线程 条件变量condition_variable

MFC ResumeThread 和 std::condition_variable 等待后偶尔线程同步失败

尝试使用 condition_variables 在线程之间切换

线程 condition_variable

如何正确使用 std::condition_variable?

详解 C++ 多线程的condition_variable