经典的同步/互斥问题—读者与写者(读者优先、写者优先、读写公平)

2024-03-10 21:10

本文主要是介绍经典的同步/互斥问题—读者与写者(读者优先、写者优先、读写公平),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

经典的同步/互斥问题—读者与写者(读者优先、写者优先、读写公平)

一、问题描述

一个数据文件或记录,可被多个进程共享,我们把只要求读该文件的进程称为“读者进程”,其他进程则称为“写者进程”。
允许多个进程同时读一个共享对象,因为读操作不会使数据文件混乱。但不允许一个写者进程和其他读者进程或写者进程同时访问共享对象。因为这种访问将会引起混乱。

在这里插入图片描述

二、问题分析

对共享资源的读写操作,任一时刻“写者”最多只允许一个,而“读者”则允许多个:
“读-写”互斥
“写-写”互斥
“读-读”允许

当读进程reader要访问数据记录有以下几种情况:
1、无进程在访问,顺利进入临界区,访问临界资源
2、已有读进程在访问,此时仍可访问临界资源,但要记录有几个读进程在访问临界资源
3、已有写进程在访问,reader阻塞

当写进程writer要访问数据记录有以下几种情况:
1、无进程在访问,顺利进入临界区,访问临界资源
2、已有读进程在访问,writer阻塞
3、已有写进程在访问,writer阻塞

三、解决过程

①解决读写互斥、写写互斥

semaphore wmutex=1;//读写互斥
void reader(){//读者do{P(wmutex);read;//读者读V(wmutex);}while(TRUE);
}void writer(){//写者do{P(wmutex);write;//写者写V(wmutex);}while(TRUE);
}

上面实现了“读写互斥”、“写写互斥”,但假设读进程A正在访问共享资源,执行了P(wmutex) “上锁 ”,还没有执行V操作解锁,此时有读进程B也想访问共享资源,此时,读进程B会被阻塞。即读进程与读进程之间也变成了必须互斥访问共享资源,并不满足“读读允许”。

②再实现“读读允许”

semaphore wmutex=1;//读写互斥
int readcount=0;//记录当前有几个读进程在访问临界资源
void reader(){//读者do{if(readcount==0)P(wmutex);readcount++;read;//读者读readcount--;if(readcount==0)V(wmutex);}while(TRUE);
}void writer(){//写者do{P(wmutex);write;//写者写V(wmutex);}while(TRUE);
}

上述方法表面上看已经满足了“读-读”允许 的条件,但其实还存在一点问题:
如果读进程A想要访问共享资源,并且执行了P(wmutex)“上锁”操作,此时(进程A执行到“readcount++”之前或“readcount- -”之后),读进程B也想要访问共享资源,由于readcount=0也会执行P(wmutex),但是因为进程A已经执行了“上锁”操作,所以进程B还是会被阻塞,无法访问共享资源。可见,仍然可能出现读进程不可同时访问共享数据的情况。
出现这个问题的原因:
对于readcount变量的检查与赋值操作无法“一气呵成”,可以被中断。
解决方法:
可以增加一个rmutex互斥信号量来保证if判断语句和readcount++(readcount–)能够“一气呵成”执行完,保证各读进程对readcount的访问是互斥的。

③保证各读进程对readcount的访问是互斥的(读者优先)

semaphore rmutex=1,wmutex=1int readcount=0void reader(){//读者do{wait(rmutex)//申请对readcount的使用if(readcount==0)wait(wmutex);//第一个读者阻止后面的写者使用readcount++;signal(rmutex);//释放对readcount的使用read;//读者读wait(rmutex);//申请对readcount的使用readcount--;if(readcount==0)signal(wmutex);//最后一个读者使用完,写者才可使用signal(rmutex);//释放对readcount的使用}while(TRUE);
}void writer(){//写者do{wait(wmutex);//申请读文件write;//写者写signal(wmutex);//释放文件资源}while(TRUE);
}

上述解决方案确实已经达到了多个读者可以同时访问共享数据的目的,但此时,又出现了新的问题:
来看这样一种情况(下面用W表示写进程,R表示读进程):
R1,R2,W1,R3顺序到达,如何访问临界资源呢?

1.首先R1访问,rmutex=1, readcount = 1, wmutex = 0
2.R1还没访问完,R2到达:因为读进程可以同时访问,所以R2也可以访问临界资源,rmutex=1, readcount=2, wmutex = 0
3.W1到达:因为wmutex为0,所以W1阻塞
4.R3到达:仍可以访问临界资源,rmutex=1, readcount=3, wmutex = 0

如果有源源不断的读进程到达,写进程W1永远也不可能访问到临界资源,就是说写者有可能会被“饿死”,违反了有限等待的这条原则。
即这种算法是“读者优先”的,为什么会这样呢?
因为在第一个读者到达时,使得wmutex为0,阻塞了后续所有的写者,读者却仍然可以访问临界资源,我们只要使得后续的读者也阻塞,这样就使得读者和写者的优先级根据到达时间先后来决定,从而解决问题。

④实现读写公平
为此,可在原来的读优先算法的基础上增加:
初值为1的信号量S,这个信号量不分读者写者,只要有进程在访问临界资源,就不允许其他进程再访问了

semaphore rmutex=1,wmutex=1, S=1;
int readcount=0, writecount=0;
void reader(){//读者do{wait(S);		//**wait(rmutex)//申请对readcount的使用if(readcount==0)wait(wmutex);//第一个读者阻止后面的写者使用readcount++;signal(rmutex);//释放对readcount的使用signal(S);		//**read;//读者读wait(rmutex);//申请对readcount的使用readcount--;if(readcount==0)signal(wmutex);//最后一个读者使用完,写者才可使用signal(rmutex);//释放对readcount的使用//signal(S);  //如果把V操作放在这里,其他的读进程也不能访问临界资源了}while(TRUE);
}void writer(){//写者do{wait(S);		//**wait(wmutex);write;//读者读signal(wmutex);//最后一个写者使用完,读者才可使用signal(S);		//**}while(TRUE);
}

此时,当R1,R2都在访问数据,W1到达阻塞使得信号量S变为0,R3到达后也不能进入临界区,只能乖乖的等着W1执行完后,再访问临界资源。由此,便实现了读写平等。

⑤写者优先
那么,想实现写者优先,如何去做?只要将写者的到达数量也统计一下,不为0,读者就不能进临界区即可:
①初值为0的整型变量writecount,用来对写者进行计数
②初值为1的互斥信号量wcMutex,用来实现多个写者对writecount进行互斥访问

semaphore S=1;
semaphore rmutex=1,wmutex=1, wcMutex=1;
int readcount=0, writecount=0;
void reader(){//读者do{wait(S);wait(rmutex)//申请对readcount的使用if(readcount==0)wait(wmutex);//第一个读者阻止后面的写者使用readcount++;signal(rmutex);//释放对readcount的使用signal(S);	read;//读者读wait(rmutex);//申请对readcount的使用readcount--;if(readcount==0)signal(wmutex);//最后一个读者使用完,写者才可使用signal(rmutex);//释放对readcount的使用}while(TRUE);
}void writer(){//写者 do{wait(wcMutex);//申请对writecount的使用if(writecount==0)wait(S);//第一个写者阻止后面的读者使用writecount++;signal(wcMutex);//释放对writecount的使用wait(wmutex);write;//读者读signal(wmutex);	wait(wcMutex);//申请对writecount的使用writecount--;if(writecount==0)signal(S);//最后一个写者使用完,读者才可使用signal(wcMutex);//释放对writecount的使用}while(TRUE);
}

可以试一下,依照上述代码,W1,W2,R1,W3的访问临界资源的顺序是怎样的。

这篇关于经典的同步/互斥问题—读者与写者(读者优先、写者优先、读写公平)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/795517

相关文章

MyBatis模糊查询报错:ParserException: not supported.pos 问题解决

《MyBatis模糊查询报错:ParserException:notsupported.pos问题解决》本文主要介绍了MyBatis模糊查询报错:ParserException:notsuppo... 目录问题描述问题根源错误SQL解析逻辑深层原因分析三种解决方案方案一:使用CONCAT函数(推荐)方案二:

Redis 热 key 和大 key 问题小结

《Redis热key和大key问题小结》:本文主要介绍Redis热key和大key问题小结,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录一、什么是 Redis 热 key?热 key(Hot Key)定义: 热 key 常见表现:热 key 的风险:二、

IntelliJ IDEA 中配置 Spring MVC 环境的详细步骤及问题解决

《IntelliJIDEA中配置SpringMVC环境的详细步骤及问题解决》:本文主要介绍IntelliJIDEA中配置SpringMVC环境的详细步骤及问题解决,本文分步骤结合实例给大... 目录步骤 1:创建 Maven Web 项目步骤 2:添加 Spring MVC 依赖1、保存后执行2、将新的依赖

Spring 中的循环引用问题解决方法

《Spring中的循环引用问题解决方法》:本文主要介绍Spring中的循环引用问题解决方法,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录什么是循环引用?循环依赖三级缓存解决循环依赖二级缓存三级缓存本章来聊聊Spring 中的循环引用问题该如何解决。这里聊

Spring Boot中JSON数值溢出问题从报错到优雅解决办法

《SpringBoot中JSON数值溢出问题从报错到优雅解决办法》:本文主要介绍SpringBoot中JSON数值溢出问题从报错到优雅的解决办法,通过修改字段类型为Long、添加全局异常处理和... 目录一、问题背景:为什么我的接口突然报错了?二、为什么会发生这个错误?1. Java 数据类型的“容量”限制

关于MongoDB图片URL存储异常问题以及解决

《关于MongoDB图片URL存储异常问题以及解决》:本文主要介绍关于MongoDB图片URL存储异常问题以及解决方案,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐... 目录MongoDB图片URL存储异常问题项目场景问题描述原因分析解决方案预防措施js总结MongoDB图

SpringBoot项目中报错The field screenShot exceeds its maximum permitted size of 1048576 bytes.的问题及解决

《SpringBoot项目中报错ThefieldscreenShotexceedsitsmaximumpermittedsizeof1048576bytes.的问题及解决》这篇文章... 目录项目场景问题描述原因分析解决方案总结项目场景javascript提示:项目相关背景:项目场景:基于Spring

解决Maven项目idea找不到本地仓库jar包问题以及使用mvn install:install-file

《解决Maven项目idea找不到本地仓库jar包问题以及使用mvninstall:install-file》:本文主要介绍解决Maven项目idea找不到本地仓库jar包问题以及使用mvnin... 目录Maven项目idea找不到本地仓库jar包以及使用mvn install:install-file基

usb接口驱动异常问题常用解决方案

《usb接口驱动异常问题常用解决方案》当遇到USB接口驱动异常时,可以通过多种方法来解决,其中主要就包括重装USB控制器、禁用USB选择性暂停设置、更新或安装新的主板驱动等... usb接口驱动异常怎么办,USB接口驱动异常是常见问题,通常由驱动损坏、系统更新冲突、硬件故障或电源管理设置导致。以下是常用解决

Mysql如何解决死锁问题

《Mysql如何解决死锁问题》:本文主要介绍Mysql如何解决死锁问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录【一】mysql中锁分类和加锁情况【1】按锁的粒度分类全局锁表级锁行级锁【2】按锁的模式分类【二】加锁方式的影响因素【三】Mysql的死锁情况【1