IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> 【操作系统】生产者消费者问题 -> 正文阅读

[大数据]【操作系统】生产者消费者问题

问题描述

系统中有一组生产者进程和一组消费者进程,生产者进程每次生产一个产品放入缓冲区,消费者进程每次从缓冲区取出一个产品并使用。(注:这里的“产品”理解为某种数据)

生产者、消费者共享一个初始为空、大小为n的缓冲区。
在这里插入图片描述

问题分析

缓冲区是有容量限制的,只有缓冲区没满时,生产者才能把产品放入缓冲区,否则必须等待

如果此时缓冲区已经满了,那么生产者如果想要继续往缓冲区写入数据的话,只能先将自己阻塞。
在这里插入图片描述
只有缓冲区不空时,消费者才能从中取出产品,否则必须等待。

消费者进程想要从缓冲区取走产品时,当一个消费者从缓冲区中取走一个产品后,生产者可以继续生产,如果此时有生产者进程是处于阻塞态的,那么消费者进程需要将生产者进程给唤醒,让它重新回到就绪态。不过生产者进程只是回到了就绪态,这并不代表生产者可以立即往缓冲区写入数据,所以接下来可能是消费者进程继续陆续从缓冲区中取走数据,需要注意的是:只有缓冲区不空的时候,消费者进程才可以从缓冲区中取走数据,不然的话消费者进程只能阻塞等待。**在这里插入图片描述
缓冲区是临界资源,各进程必须互斥地访问

假如此时有两个生产者进程正在并发的运行中,第一个生产者进程发现缓冲区都是空的,选择了一块区域进行写入数据,第二个生产者进程并发运行中也发现了缓冲区都是空的,选择了与前一个生产者进程同一块区域进行写入数据,那么第二个生产者写入的数据会覆盖掉前一个生产者写入的数据。
在这里插入图片描述

只有当缓冲区有产品(缓冲区不空)的时候,消费者才能进行消费,只有当缓冲区没满的时候,生产者才能进行生产。所以此时我们需要设置两个同步信号量 full 和 empty。然后分别在前后的动作执行PV操作。

semaphore mutex = 1;  //互斥信号量,实现对缓冲区的互斥访问
semaphore empty = n;  //同步信号量,表示空闲缓冲区的数量
semaphore full = 0;  //同步信号量,表示产品的数量,也即非空缓冲区的数量

producer(){		//生产者进程
	while(1){
		生产一个产品;
		P(empty); //消耗一个空闲缓冲区 
		P(mutex); //对进程上锁
		把产品放入缓冲区;
		V(full);  //增加一个产品,资源数量加1
		V(full);  //对进程解锁
	}
}

consumer(){		//消费者进程
	while(1){
		从缓冲区取出一个产品;
		P(full);  //消耗一个产品(非空缓冲区)
		P(mutex); //对进程上锁
		使用产品;
		V(empty);  //增加一个空闲缓冲区
		V(full);  //对进程解锁
	}
}

实现互斥是在同一进程中进行一对PV操作。
实现两进程的同步关系,是在其中一个进程中执行P,另一进程中 执行V。执行V操作的进程会唤醒对应的执行P操作的进程
在这里插入图片描述
在这里插入图片描述
有时候是消费者需要等待生产者生产,有时候是生产者需要等待消费者消费,这是两个不同的“一前一后的问题”,因此也需要设置两个同步的信号量。在这里插入图片描述
实现互斥和实现同步的两个P操作的先后顺序(死锁问题),实现互斥的p操作必须在实现同步的p操作之后,否则会导致死锁问题。

  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2021-12-15 18:21:59  更:2021-12-15 18:23:10 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 12:05:35-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码