condition

转载
https://www.cnblogs.com/-citywall123/p/12774088.html
https://www.cnblogs.com/xiaohaigegede/p/14008121.html

一、总述
在C++11中，我们可以使用条件变量（condition_variable）实现多个线程间的同步操作；当条件不满足时，相关线程被一直阻塞，直到某种条件出现，这些线程才会被唤醒。

主要成员函数如下

1、wait函数：
（1）wait（unique_lock ＆lck）

当前线程的执行会被阻塞，直到收到 notify 为止。

（2）wait（unique_lock ＆lck，Predicate pred）

当前线程仅在pred=false时阻塞；如果pred=true时，不阻塞。

wait（）可依次拆分为三个操作：释放互斥锁、等待在条件变量上、再次获取互斥锁

2、notify_one：
notify_one()：没有参数、没有返回值。

解除阻塞当前正在等待此条件的线程之一。如果没有线程在等待，则还函数不执行任何操作。如果超过一个，不会指定具体哪一线程。

实例

//编写一个程序,开启3个线程,这3个线程的ID分别为A、B、C,每个线程将自己的ID在屏幕
#include
#include 
#include 
#include
#include 
int num = 0;
std::mutex _mutex;
std::condition_variable cv;

void thread_func(int id)
{
    for (int i = 0; i < 10; i++)
    {
        //注意锁的类型
        std::unique_lock  lg(_mutex);

        //线程id！=num的会被阻塞
        while (id != num)
            cv.wait(lg);

        printf("%c", id + 'A');
        num = (num + 1) % 3;
        //当线程号为id的线程执行完之后，唤醒其它线程重新竞争锁
        cv.notify_all();
    }
}

int main()
{
    int i;
    std::thread p[3];
    //创建三个线程，分别负责打印ABC
    for (i = 0; i < 3; i++)
        p[i] = std::thread(thread_func, i);
    for (i = 0; i < 3; i++)
        p[i].join();
    system("pause");
    return 0;
}