生产者消费问题以及多生产者—消费者问题实现思想
一、生产者消费问题
- 系统中有一组生产者进程和一组消费者进程,生产者进程每次生产一个产品放入缓冲区,消费者
- 进程每次从缓冲区中取出一个产品并使用。(注:这里的“产品”理解为某种数据)
- 生产者、消费者共享一个初始为空、大小为n的缓冲区。
- 只有 缓冲区没满 时,生产者才能把产品放入缓冲区,否则必须等待。 【缓冲区没满→生产者生产】
- 只有 缓冲区不空 时,消费者才能从中取出产品,否则必须等待。 【缓冲区没空→消费者消费】
- 缓冲区是临界资源,各进程必须互斥地访问。
- PV操作题目分析步骤:
①、关系分析。找出题目中描述的各个进程,分析它们之间的同步、互斥关系。
②、整理思路。根据各进程的操作流程确定P、V操作的大致顺序。【生产者每次要消耗§一个空闲缓冲区,并生产(V)一个产品。消费者每次要消耗(P)一个产品,并释放一个空闲缓冲区V) 。往缓冲区放入/取走产品需要互斥。】
③、设置信号量。并根据题目条件确定信号量初值。(互斥信号量初值一般为1,同步信号量的初
始值要看对应资源的初始值是多少)
(一)能否改变相邻P、V操作的顺序?
- 若此时缓冲区内已经放满产品,则 empty=0,full=n。
- 则生产者进程执行① 使mutex变为0,再执行②,由于已没有空闲缓冲区,因此生产者被阻塞。
- 由于生产者阻塞,因此切换回消费者进程。消费者进程执行③,由于mutex为0,即生产者还没释放对临界资源的“锁”,因此消费者也被阻塞。
- 这就造成了生产者等待消费者释放空闲缓冲区,而消费者又等待生产者释放临界区的情况,生产者和消费者循环等待被对方唤醒,出现“死锁”。
- 同样的,若缓冲区中没有产品,即full=0,empty=n。按③④① 的顺序执行就会发生死锁。
- 因此, 实现互斥的P操作一定要在实现同步的P操作之后。
V操作不会导致进程阻塞,因此 两个V操作顺序可以交换。
- 生产者消费者问题是一个互斥、同步的综合问题。
- 有时候是消费者需要等待生产者生产,有时候是生产者要等待消费者消费,这是两个不同的“一前一后问题”,因此也需要设置两个同步信号量。
二、多生产者—消费者问题
- 桌子上有一只盘子,每次只能向其中放入一个水果。爸爸专向盘子中放苹果,妈妈专向盘子中放橘子,儿子专等着吃盘子中的橘子,女儿专等着吃盘子中的苹果。只有盘子空时,爸爸或妈妈才可向盘子中放一个水果。仅当盘子中有自己需要的水果时,儿子或女儿可以从盘子中取出水果。
- 用PV操作实现上述过程。
- 关系分析。找出题目中描述的各个进程,分析它们之间的同步、互斥关系。
- 整理思路。根据各进程的操作流程确定P、V操作的大致顺序。【互斥:在临界区前后分别PV;同步:前V后P】
- 设置信号量。设置需要的信号量,并根据题目条件确定信号量初值。(互斥信号量初值一般为1,同步信号量的初始值要看对应资源的初始值是多少)
(一)如何实现?
(二)问题:可不可以不用互斥信号量?
- 分析:刚开始,儿子、女儿进程即使上处理机运行也会被阻塞。如果刚开始是父亲进程先上处理机运行,则:父亲 P(plate),可以访问盘子→母亲 P(plate),阻塞等待盘子→父亲放入苹果V(apple),女儿进程被唤醒,其他进程即使运行也都会阻塞,暂时不可能访问临界资源(盘子)→女儿 P(apple),访问盘子,V(plate),等待盘子的母亲进程被唤醒à母亲进程访问盘子(其他进程暂时都无法进入临界区)→……
- 结论:即使不设置专门的互斥变量mutex,也不会出现多个进程同时访问盘子的现象
- 原因在于:本题中的缓冲区大小为1,在任何时刻,apple、orange、plate 三个同步信号量中最多只有一个是1。因此在任何时刻,最多只有一个进程的P操作不会被阻塞,并顺利地进入临界区…
(三)如果盘子(缓冲区)容量为2
- 父亲 P(plate),可以访问盘子→母亲 P(plate),可以访问盘子→父亲在往盘子里放苹果,同时母亲也可以往盘子里放橘子。于是就出现了两个进程同时访问缓冲区的情况,有可能导致两个进程写入缓冲区的数据相互覆盖的情况。
- 因此,如果缓冲区大小大于1,就必须专门设置一个互斥信号量 mutex 来保证互斥访问缓冲区。
- 总结:在生产者-消费者问题中,如果缓冲区大小为1,那么有可能不需要设置互斥信号量就可以实现互斥访问缓冲区的功能。当然,这不是绝对的,要具体问题具体分析。
- 建议:在考试中如果来不及仔细分析,可以加上互斥信号量,保证各进程一定会互斥地访问缓冲区。但需要注意的是,实现互斥的P操作一定要在实现同步的P操作之后,否则可能引起“死锁”
- PV 操作题目的解题思路:
①、关系分析。找出题目中描述的各个进程,分析它们之间的同步、互斥关系。
②、整理思路。根据各进程的操作流程确定P、V操作的大致顺序。
③、设置信号量。设置需要的信号量,并根据题目条件确定信号量初值。(互斥信号量初值一般为1,同步信号量的初始值要看对应资源的初始值是多少)
- 解决“多生产者-多消费者问题”的关键在于理清复杂的同步关系。
- 在分析同步问题(一前一后问题)的时候不能从单个进程行为的角度来分析,要把“一前一后”发生的事看做是两种“事件”的前后关系。
- 比如,如果从单个进程行为的角度来考虑的话,我们会有以下结论:
①、如果盘子里装有苹果,那么一定要女儿取走苹果后父亲或母亲才能再放入水果
②、如果盘子里装有橘子,那么一定要儿子取走橘子后父亲或母亲才能再放入水果 - 这么看是否就意味着要设置四个同步信号量分别实现这四个“一前一后”的关系了?
正确的分析方法应该从“事件”的角度来考虑,我们可以把上述四对“进程行为的前后关系”抽象为一对“事件的前后关系” - 盘子变空事件→放入水果事件。“盘子变空事件”既可由儿子引发,也可由女儿引发;“放水果事件”
- 既可能是父亲执行,也可能是母亲执行。这样的话,就可以用一个同步信号量解决问题了
生产者消费问题以及多生产者—消费者问题实现思想相关推荐
- 用三个线程实现生产者消费者模型,其中一个线程作为生产者,二个线程作为消费者,生产者随机生产一个时间戳或者字符串,消费者消费这个时间戳,并不能重复消费,并将其打印出来
题目要求: 用三个线程实现生产者消费者模型,其中一个线程作为生产者,二个线程作为消费者,生产者随机生产一个时间戳或者字符串,消费者消费这个时间戳,并不能重复消费,并将其打印出来.(这是一道百度面试的算 ...
- 2.6操作系统(生产者消费问题 多生产者—消费者问题 吸烟者问题)
目录 1.生产者消费问题 能否改变相邻P.V操作的顺序? 2.多生产者-消费者问题 如何实现? 可不可以不用互斥信号量? 如果盘子(缓冲区)容量为2 知识回顾与重要考点 3.吸烟者问题 如何实现 个 ...
- java消费者和生产者模型_Java实现简易生产者消费者模型过程解析
一.概述 一共两个线程,一个线程生产产品,一个线程消费产品,使用同步代码块方法,同步两个线程.当产品没有时,通知生产者生产,生产者生产后,通知消费者消费,并等待消费者消费完. 需要注意的是,有可能出现 ...
- kafka消费者如何读同一生产者消息_Kafka入门之生产者消费者
一.Kafka安装与使用 ( kafka介绍 ) 1. 下载Kafka 2. 安装 Kafka是使用scala编写的运行与jvm虚拟机上的程序,虽然也可以在windows上使用,但是kafka ...
- 生产者消费模型-管程法
并发协作模型"生产者/消费者模式"->管程法 生产者:负责生产数据的模块(可能是方法,对象,线程,进程): 消费者:负责处理数据的模块(可能是方法,对象,线程,进程): 缓冲 ...
- redis队列生产消费php,redis 队列 生产者 消费者模式
1. 生产者: //publish.php $redis = new Redis(); $redis->pconnect('10.10.10.252',6379); $redis->aut ...
- 多线程经典模型-生产者消费
需求:生产者生产一个,消费者消费一个 问题引出 class Info{private String name;private String desc;public Info(){}public Inf ...
- 利用互斥锁和条件变量实现生产者消费模型
以下内容全部来自于自旋锁_哔哩哔哩_bilibili #include <stdio.h> #include <pthread.h> #include <stdlib.h ...
- 生产者(厨师做面条)消费者(吃货吃面条)模式synchronized 法和Lock+Condition法(不使用集合),代码详解
1. synchronized + wait + notifyAll synchronized:包裹着同步代码块,代码块执行完释放锁 wait:线程挂起,失去锁 notifyAll:唤醒同个对象的wa ...
最新文章
- GRNet网络:3D网格进行点云卷积,实现点云补全
- 委托、lamda表达式..委托概念-匿名函数-泛型委托-Lamda表达式-多播委托
- 前端智能化的加速时刻:华为机器视觉的创新方程式
- CSDN中对Web自定义控件的讨论帖
- svn 面板缺少可选项_TortoiseSVN的设置
- 《正则表达式经典实例(第2版)》——2.6 匹配完整单词
- 迁移 Spring Boot 到函数计算
- 设置双核浏览器的浏览模式meta name=“renderer” content=“webkit|ie-comp|ie-stand”
- 开发者应警惕的七种糟糕职业规划错误
- 数据结构链表之队列,Python3实现——7
- 10年老分析师:数据分析不只是一个岗位,更是一种职场必备能力
- Mysql中Check约束无效的原因以及解决方法
- envi与arcgis文件转换_ArcGIS ENVI中土地分类格式互转、土地利用转移矩阵、变化图谱计算详解...
- 【禁忌搜索】基于禁忌搜索算法实现经典VRP问题的matlab仿真
- Solr实现全文检索
- python的复数的实部虚部都是浮点数吗_python中复数的共轭复数知识点总结
- 安卓--记账软件课程设计
- java抠图人物背景图片_人物抠图换背景两种实用方法!
- 实现mysql主从复制
- LeetCode刷题日记2022-2-28/1601. 最多可达成的换楼请求数目-排列组合
热门文章
- 【香蕉OI】GCD 和 LCM (莫比乌斯反演)
- 计算机浏览器无法上网怎么办,电脑浏览器上不了网,其他上网正常,怎么解决...
- 谷歌移动端seo优化如何做
- android光度传感器开发,Android开发之光线传感器用法
- Duplicate entry 'sang' for key 'UK_f8t9fsfwc17s6qcbx0ath6l3h'
- kafka启动异常InconsistentClusterIdException
- RNA-ATTO 390|RNA-ATTO 425|RNA-ATTO 465|RNA-ATTO 488|RNA-ATTO 495|RNA-ATTO 520近红外荧光染料标记核糖核酸RNA
- android kotlin 上传文件 上传图片
- rt-n13u无线打印机服务器,全能表现 华硕RT-N13U无线路由器评测
- LaTeX易忘符号小结,如何打限制条件?如何打分段函数?如何打花体英文?