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

2020/10/11 11:23

问题

设计C/C++程序(可以嵌入汇编语言)，以忙等待方式实现信号量及其P、V操作。利用你实现的信号量，实现生产者-消费者问题。给出实现方法、主要源代码和测试结果。

代码

# include<iostream>
# include<thread>
# include<vector>
# include<mutex>
# include<condition_variable>
# include<queue>
#include <ctime>
#include <windows.h>
using namespace std;# define PRODUCT_SIZE 5//生产者数量
# define CUSTOMER_SIZE 20//消费者数量
#define MAX_SIZE 10//最大产品数量
mutex mut;//互斥锁
condition_variable con;//条件变量
queue<int> que;//队列，模拟缓冲区
void Producter()
{while (true){Sleep(10);srand(int (time(NULL)));std::unique_lock <std::mutex> lck(mut);/*当 std::condition_variable对象的某个wait 函数被调用的时候，它使用 std::unique_lock(通过 std::mutex) 来锁住当前线程。当前线程会一直被阻塞，直到另外一个线程在相同的 std::condition_variable 对象上调用*/while (que.size() > MAX_SIZE)//当队列已满时等待，不再生产{con.wait(lck);//P操作}int data = rand();//随机产生数字代表商品的生产que.push(data);//将数据推入队列代表商品加入缓冲区cout << this_thread::get_id() << "生产了产品：" << data << endl;Sleep(500);con.notify_all();//唤醒所有等待的进程，即V操作}
}
void Customer()
{while (true){std::unique_lock <std::mutex> lck(mut);while (que.empty())//当队列为空时等待，不再消费{//用condition_variable对象实现对缓冲区的互斥操作con.wait(lck);//P操作}cout << this_thread::get_id() << "消费了产品：" << que.front() << endl;Sleep(500);que.pop();con.notify_all();//唤醒所有等待的进程，即V操作}
}
int main()
{vector<thread> threadPoll;//创建生产者和消费者for (int i = 0; i < PRODUCT_SIZE; ++i){threadPoll.push_back(thread(Producter));}for (int i = 0; i < PRODUCT_SIZE + CUSTOMER_SIZE; ++i){threadPoll.push_back(thread(Customer));}for (int i = 0; i < PRODUCT_SIZE + CUSTOMER_SIZE; ++i){threadPoll[i].join();//原始线程等到新线程执行完毕后再销毁}return 0;
}

运行截图

1.利用条件变量condition_variable实现PV操作，当condition_variable对象的某个wait 函数被调用的时候，它使用 unique_lock(通过 mutex) 来锁住当前线程。当前线程会一直被阻塞，直到另外一个线程在相同的condition_variable 对象上调用
2.用产生的随机数字代表商品的生产，加入队列表示加入缓冲区
3.线程销毁采用join方式，等待新线程执行完毕再销毁原始线程

生产者消费者问题C++实现相关推荐

RabbitMQ 入门系列（3）— 生产者消费者 Python 代码实现
生产者消费者代码示例上一章节中对消息通信概念做了详细的说明,本章节我们对 RabbitMQ 生产者和消费者代码分别做一示例说明. 1. 生产者代码 #!/usr/bin/env python # c ...
【C++】多线程(链式、循环队列)实现生产者消费者模式
生产者消费者模式: 生产者消费者问题(英语:Producer-consumer problem),也称有限缓冲问题(英语:Bounded-buffer problem),是一个多线程同 ...
面试官让我手写一个生产者消费者模式？
不知道你是否遇到过面试官让你手写生产者消费者代码.别说,前段时间有小伙伴还真的遇到了这种情况,当时是一脸懵逼. 但是,俗话说,从哪里跌倒就要从哪里爬起来.既然这次被问到了,那就回去好好研究一下,争取下 ...
windows进程生产者消费者代码c语言,生产者消费者问题---C语言实现
生产者消费者问题(Producer-consumer problem) 是一个多线程同步问题的经典案例. 生产者的主要作用是生成一定量的数据放到缓冲区中,然后重复此过程.与此同时,消费者也在缓冲区消耗 ...
基于队列的生产消费设计java_生产者-消费者设计模式
一.生产者消费者设计模式 1.中间队列一段内存空间,且可存取: 2.两种角色 (1)生产者:生产数据: (2)消费者:消费数据. 3.三种关系 (1)生产者与生产者的互斥关系: (2)消费者与消费者 ...
用三个线程实现生产者消费者模型，其中一个线程作为生产者，二个线程作为消费者，生产者随机生产一个时间戳或者字符串，消费者消费这个时间戳，并不能重复消费，并将其打印出来
题目要求: 用三个线程实现生产者消费者模型,其中一个线程作为生产者,二个线程作为消费者,生产者随机生产一个时间戳或者字符串,消费者消费这个时间戳,并不能重复消费,并将其打印出来.(这是一道百度面试的算 ...
生产者/消费者模型详解（基于Java）
title: 生产者消费者模型 tags: 多线程 synchronized 锁 wait() notify() 生产者/消费者模型原理以及代码实现一.生产者/消费者模型原理所谓的生产者消费者模型 ...
java线程模拟生产者消费者问题
所谓的生产者消费者问题,就是存在生产者和消费者两个线程,当仓库还没满的时候,生产者可以生产,当仓库没空的时候,消费者可以取走商品. 我们用实例说话: 下面,我们创建几个类: 1.消费者--主要负责消费 ...
图文并茂的生产者消费者应用实例demo
前面的几篇文章<<.NET 中的阻塞队列BlockingCollection的正确打开方式>><<项目开发中应用如何并发处理的一二事>>从代码以及理论角 ...
linux使用线程实现生产者消费者问题,Linux平台下线程同步，实现“生产者消费者问题”...
(1)线程同步,实现"生产者消费者问题" 要求:缓冲区大小为20,生产者每次放一个产品,消费者每次取走一个产品:生产者和消费者至少2个. (2)代码如下: #include #in ...

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

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

问题

代码

运行截图

生产者消费者问题C++实现相关推荐

最新文章

热门文章