// Dexic.cpp: 定义控制台应用程序的入口点。
//
#include "stdafx.h"
#include <Windows.h>
#include <mutex>
#include <condition_variable>
#include <deque>
#include <iostream>
using namespace std;
std::condition_variable QueueNotFull;
std::condition_variable QueueNotEmpty;
std::mutex QueueMutex;
std::deque<int> Que;
const int MaxSize = 10;
bool isEmpty() {
return Que.empty();
}
bool isFull() {
return Que.size() == MaxSize;
}
void dataPut(int element) {
std::unique_lock<std::mutex> locker(QueueMutex);
while (isFull() )
{
cout << "Queue is Full !!" << endl;
QueueNotFull.wait(locker);
}
Que.push_back(element);
QueueNotEmpty.notify_all();
}
int dataGet() {
std::unique_lock<std::mutex> locker(QueueMutex);
while (isEmpty())
{
cout << "Queue is Empty !!" << endl;
QueueNotEmpty.wait(locker);
Sleep(1000);
}
int t = Que.front();
Que.pop_front();
QueueNotFull.notify_all();
return t;
}
void getFunc() {
while (1) {
int var;
var = dataGet();
cout << "Get data :" << var << endl;
Sleep(1000);
}
}
void putFunc() {
//srand((unsigned int)time(0));
int i = 0;
while (i < 100) {
dataPut(i++);
//int var = rand() % 100;
//dataPut(var);
}
}
int main(int arc, char** argv)
{
cout << "Hello World" << endl;
std::thread td1(getFunc);
std::thread td2(putFunc);
td1.join();
td2.join();
return 0;
}
image.png
