#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 = ; i < num; i++)
{
unique_lock<mutex> lk(m);//锁定
while (myint.size() >= )
{
//一直等待有空位才生产
isempty.wait(lk);
} myint.push_back(i);
cout << "生产了" << i << endl;
//激活isfull
isfull.notify_all(); this_thread::sleep_for(chrono::milliseconds());
}
flag = false;
} void take()
{
while (flag)
{
unique_lock<mutex> lk(m);//锁定
while (myint.size() == )
{
//一直等待有生产后才执行,(等待到激活后才可以执行)
isfull.wait(lk);
} if (flag)
{
cout << "消费了" << myint[myint.size() - ] << endl;
myint.pop_back();//消除
//激活isempty
isempty.notify_all();
}
}
} void main()
{
thread t1(take);
thread t2(take);
thread t3(take);
thread t4(put,);
cin.get();
}