C++生产者消费者问题实例

全局变量声明

#include <iostream>
#include <condition_variable>
#include <mutex>
#include <thread>
 
static const int repository_size = 10;//循环队列的大小
static const int item_total = 20;//要生产的产品数目
 
std::mutex mtx;//互斥量，保护产品缓冲区
 
std::condition_variable repo_not_full;//条件变量指示产品缓冲区不满
std::condition_variable repo_not_empty;//条件变量指示产品缓冲区不为空，就是缓冲区有产品
 
int item_buffer[repository_size];//产品缓冲区，它是一个数组，用于存储生产者生成的产品（即消费者消费的产品）
 
static std::size_t read_position = 0;//消费者读取产品的位置
static std::size_t write_position = 0;//生产者写入产品的位置
 
std::chrono::seconds t(1);//a  new feature of c++ 11 standard

生产者生产函数

void produce_item()
{
	...
}

消费者消费函数

void consume_item()
{
	...
}

生产者线程入口

生产者线程入口——生产者线程会循环调用produce_item函数，不断生产产品放入产品缓冲区

void Produce_thread()
{
	while(1)
	{
		produce_item();
	}
}

消费者线程入口

消费者线程入口——消费者线程会循环调用consume_item函数，不断消费产品并处理产品

void Consume_thread()
{
	static int cnt = 0;
	while(1)
	{
	consume_item();
	}
}

主函数

int main()
{
	std::thread producer(Producer_thread);// 创建生产者线程
	std::thread consumer(Consumer_thread);// 创建消费者线程
	producer.join();
	consumer.join();

	return 0;
}

参考博文：C++ 生产者消费者 四种情况