simple consumer and producer

consumer_producer.cpp

#include <iostream>
#include <stdio.h>
#include <stack>
#include <vector>
#include <string>
#include <exception>
#include <mutex>
#include <thread>
#include <condition_variable>
#include <queue>
using namespace std;

mutex mtx;
condition_variable cv;
queue<int> q;
int a = 0;

void process()
{
	while (true)
	{
		unique_lock<mutex> ul(mtx);
		while (q.empty())
		{
			cv.wait(ul);
		}
		int t = q.front();
		q.pop();
		ul.unlock();

		cout << "process " << t << endl;
	}
}

void producer()
{
	lock_guard<mutex> lg(mtx);
	q.push(a);
	cout << "producer " << a << endl;
	a++;
	cv.notify_one();
}



int main()
{
	thread t1(process);
//	thread t2(producer);
//	t2.join();
	for (int i = 0; i < 10; i++)
		producer();

	t1.join();
}