信号量(semaphore):解决并发问题的有力工具

2024-03-24 09:36

本文主要是介绍信号量(semaphore):解决并发问题的有力工具,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

信号量(semaphore):解决并发问题的有力工具


  记得操作系统课程中,导师曾提出一个引人深思的观点:“信号量几乎可以应对所有的并发问题。”虽然这句话的真实度有待商榷,但不可否认的是,信号量为我们提供了一种更为灵活的方式来处理并发控制难题。

抽象数据类型

  想象一下现实世界中的交通信号灯作为信号量 sem,当 C 车辆欲通过路口执行 P() 操作时,若 sem 小于零,则车辆需等待;只有在 A 车或 B 车完成路口通行并执行 V() 操作后,sem 值加 1,C 车才能接收到信号继续前行。
在这里插入图片描述
  信号量(sem)使用一个整型来表示,有两个原子操作,P操作和V操作:
  P()操作:sem - 1,如果sem < 0则当前线程等待且释放占有资源,否则继续。这里我们可以理解为Java中wait()方法。
  V()操作:sem + 1,如果sem <= 0唤醒一个等待的P,进入临界区。这里我们可以理解为Java中notify()方法。

信号量的实现方式

 信号量主要分为两类:二进制信号量和计数信号量。

  • 二进制信号量,直观来说,利用 0 和 1 表示信号量的两种状态。
  • 计数信号量,具有大于零的初始值,该值只能通过 P、V 操作递减或递增。初始化时设置为大于零的值,意味着可以允许多个执行 P 操作的线程在满足条件的情况下顺利进入相应的临界区。

二进制信号量的运用

  • 二进制信号量实现互斥:通过给定信号量一个初始值,并确保 P、V 操作配对出现,即可实现在多线程间互斥访问资源。
```伪代码// 定义一个mutex信号量且初始值为1// 这里初始值设为1,是要使得首次一定会进入临界区mutex = new Semaphore(1);// 进入临界区前执行p()操作,mutex - 1mutex -> p();···// 临界区代码···// 退出临界区执行v()操作,mutex + 1mutex -> v();
  • 二进制信号量实现同步:在线程 A 必须等待线程 B 达到特定阶段后才可执行时,采用二进制信号量进行同步控制,初始值设为 0,以便 A 线程执行 P 操作时会被挂起等待。
```伪代码
// 创建一个 condition 信号量,初始值为 0
condition = new Semaphore(0);// 线程 A 执行 p() 操作进入等待状态
Thread A:...condition -> p();...// 线程 B 执行 v() 操作唤醒线程 A
Thread B:...condition -> v();...

计数信号量的使用

  面对更为复杂的并发场景,计数信号量展现出了其独特的优势。

计数信号量实现互斥与同步

  考虑经典的生产者-消费者问题,假设存在一个共享缓冲区,生产者向其中填充数据,消费者从中取出数据,系统需满足以下条件:

  1. 同一时刻只有一个线程能操作缓冲区(互斥);
  2. 缓冲区为空时,消费者需等待生产者(同步);
  3. 缓冲区满时,生产者需等待消费者(同步)。

为此,我们定义三个信号量来保证这些约束得以满足:

  • 二进制信号量,负责实现线程间的互斥;
  • 计数信号量 emptyBuffer,记录缓冲区为空的情况;
  • 计数信号量 fullBuffer,记录缓冲区满载的情况。
```伪代码
class Buffer{// 定义二进制信号量用于缓冲区buffer互斥mutex = new Semaphore(1);// 定义计数信号量fullBuffer// 初始值为表示缓冲区buffer一开始是空的fullBuffer = new Semaphore(0);// 定义计数信号量emptyBuffer// 初始值为缓冲区buffer的最大值,emptyBuffer = new Semaphore(n);
}// 生产者生产操作
deposit(c){// 计数信号量emptyBuffer,检查是否已满载(0表示满载)// 计数信号量emptyBuffer执行p操作,-1// 初始值为n且大于0,表示可重复进入n次或者n个生产者emptyBuffer -> p();// 二进制信号量mutex执行p操作,检查是否可进入临界区mutex -> p();···add c to buffer···// 二进制信号量mutex执行v操作mutex -> v();// 计数信号量fullBuffer,告诉消费者取数据// 计数信号量fullBuffer执行v操作,+1fullBuffer -> v();
}// 消费者消费操作
remove(c){// 计数信号量fullBuffer,检查是否为空,-1// 因为fullBuffer的初始值为0,则一开始消费者无法进入缓冲区buffer进行取数据fullBuffer -> p();// 二进制信号量mutex执行p操作,检查是否可进入临界区mutex -> p();···add c to buffer···// 二进制信号量mutex执行v操作mutex -> v();// 计数信号量emptyBuffer,告诉生产者生产,+1emptyBuffer -> v();
}

关于 P、V 操作顺序的探讨

  文中指出,V 操作仅涉及信号量加 1 并唤醒一个线程,所以这里的 V 操作顺序是可以任意交换而不影响程序逻辑的。然而,P 操作的执行顺序则至关重要。例如,在生产者逻辑中,不能随意交换 emptyBuffer -> p()mutex -> p() 的顺序。若交换后,当缓冲区已满时,新来的生产者可能会先获取到互斥锁,然后尝试减少 emptyBuffer 信号量并陷入等待,从而导致持有互斥锁不放,其他线程无法获得锁,进而产生死锁现象。

  综上所述,本文详尽地解释了信号量的基本概念和如何在不同的并发场景中应用二进制信号量与计数信号量实现互斥和同步控制,并通过实例剖析了操作顺序对程序正确性的影响,是一篇对信号量原理及实践有着深入解析的文章。通过这样的整理和讲解,希望能帮助读者更好地理解和掌握信号量在解决并发问题方面的强大能力。


一键三连,让我的信心像气球一样膨胀!

这篇关于信号量(semaphore):解决并发问题的有力工具的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



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

相关文章

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基

最详细安装 PostgreSQL方法及常见问题解决

《最详细安装PostgreSQL方法及常见问题解决》:本文主要介绍最详细安装PostgreSQL方法及常见问题解决,介绍了在Windows系统上安装PostgreSQL及Linux系统上安装Po... 目录一、在 Windows 系统上安装 PostgreSQL1. 下载 PostgreSQL 安装包2.

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

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

Mysql如何解决死锁问题

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

SpringBoot内嵌Tomcat临时目录问题及解决

《SpringBoot内嵌Tomcat临时目录问题及解决》:本文主要介绍SpringBoot内嵌Tomcat临时目录问题及解决,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,... 目录SprinjavascriptgBoot内嵌Tomcat临时目录问题1.背景2.方案3.代码中配置t

SpringBoot使用GZIP压缩反回数据问题

《SpringBoot使用GZIP压缩反回数据问题》:本文主要介绍SpringBoot使用GZIP压缩反回数据问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录SpringBoot使用GZIP压缩反回数据1、初识gzip2、gzip是什么,可以干什么?3、Spr

MySql match against工具详细用法

《MySqlmatchagainst工具详细用法》在MySQL中,MATCH……AGAINST是全文索引(Full-Textindex)的查询语法,它允许你对文本进行高效的全文搜素,支持自然语言搜... 目录一、全文索引的基本概念二、创建全文索引三、自然语言搜索四、布尔搜索五、相关性排序六、全文索引的限制七