首页 / C++ / c++并发练习---生产者消费者模型

c++并发练习---生产者消费者模型

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了c++并发练习---生产者消费者模型，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1590字，纯文字阅读大概需要3分钟。

内容图文

问题：有一个生产者，多个消费者，生产者每生产一个，放入队列，多个消费者顺序从队列中取出数据，打印最终结果。

分析：首先这题，我本意应该设计成如下模型：生产者单开一个线程，向队列中放入数据，而消费者在锁的保护下，从队列中去数据。但是在实际编程中，发现在队列只有100个数的情况，线程不切换，当队列数据多的时候，会发生切换，但是也不是我所想象的那种随机切换，思考至今，也没有一个合理的解释/(ㄒoㄒ)/~~。最后我把题目改成了生产者没生产一个数据，就通知消费者去取，这样保证了一定的同步，但是估计或许开销会大一些。。。

如果大家有什么好的方法或者解释，请联系我，谢谢

#include<iostream>
#include<thread>
#include<mutex>;
#include<condition_variable>
#include<queue>
#include<vector>
std::mutex mut;
std::condition_variable empty, full;
std::queue<int> Q;
int flag;
bool over = false;

void conduct(int num, int count)
{
	for (int i = 0; i < num; i++)
	{
		std::unique_lock<std::mutex> lk(mut);
		empty.wait(lk);
		Q.push(i);
		flag = i % count;
		full.notify_all();
		lk.unlock();
	}
	over = true;
}
void consumer(int id, int count)
{
	while (true)
	{
		std::unique_lock<std::mutex> lk(mut);
		full.wait(lk, [&]() {return flag == id; });

		if (!Q.empty())
		{
			int i = Q.front();
			Q.pop();
			std::cout << "thread " << id << " get " << i << std::endl;
		}

		if (over)
			break;
		empty.notify_one();
	}

	flag = (id==count-1?0:id+1);
	full.notify_all();
}

int main()
{
	int count;
	int num;
	std::vector<std::thread> threads;
	std::cout << "请输入需要生产的数量" << std::endl;
	std::cin >> num;
	std::cout << "请输入同时进行的线程数:" << std::endl;
	std::cin >> count;
	std::thread t1(conduct, num, count);
	for (int i = 0; i < count; i++)
		threads.push_back(std::thread(consumer, i, count));

	t1.join();
	for (auto &t : threads)
		t.join();
}

技术分享

原文：http://www.cnblogs.com/break-python/p/5557438.html

内容总结

以上是互联网集市为您收集整理的c++并发练习---生产者消费者模型全部内容，希望文章能够帮你解决c++并发练习---生产者消费者模型所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1126737.html

来源：【匿名】