#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();

 }