41.C++多线程生产消费者模型

#include <iostream>
#include <thread>
#include <mutex>
#include <condition_variable>
#include <array>
#include <vector>
using namespace std;

//通过mutex 等待事件响应
condition_variable isfull, isempty;//处理两种情况
mutex m;
bool flag = true;//标识,消费完了就退出
vector<int> myint;//开辟十个元素

void put(int num)
{
    for (int i = 0; i < num; i++)
    {
        unique_lock<mutex> lk(m);//锁定
        while (myint.size() >= 10)
        {
            //一直等待有空位才生产
            isempty.wait(lk);
        }

        myint.push_back(i);
        cout << "生产了" << i << endl;
        //激活isfull
        isfull.notify_all();
        
        this_thread::sleep_for(chrono::milliseconds(500));
    }
    flag = false;
}

void take()
{
    while (flag)
    {
        unique_lock<mutex> lk(m);//锁定
        while (myint.size() == 0)
        {
            //一直等待有生产后才执行,(等待到激活后才可以执行)
            isfull.wait(lk);
        }

        if (flag)
        {
            cout << "消费了" << myint[myint.size() - 1] << endl;
            myint.pop_back();//消除
            //激活isempty
            isempty.notify_all();
        }
    }
}

void main()
{
    thread t1(take);
    thread t2(take);
    thread t3(take);
    thread t4(put,100);
    cin.get();
}