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++ 生产者消费者 四种情况