信号量(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

相关文章

springboot循环依赖问题案例代码及解决办法

《springboot循环依赖问题案例代码及解决办法》在SpringBoot中,如果两个或多个Bean之间存在循环依赖(即BeanA依赖BeanB,而BeanB又依赖BeanA),会导致Spring的... 目录1. 什么是循环依赖?2. 循环依赖的场景案例3. 解决循环依赖的常见方法方法 1:使用 @La

Java并发编程必备之Synchronized关键字深入解析

《Java并发编程必备之Synchronized关键字深入解析》本文我们深入探索了Java中的Synchronized关键字,包括其互斥性和可重入性的特性,文章详细介绍了Synchronized的三种... 目录一、前言二、Synchronized关键字2.1 Synchronized的特性1. 互斥2.

Python基于wxPython和FFmpeg开发一个视频标签工具

《Python基于wxPython和FFmpeg开发一个视频标签工具》在当今数字媒体时代,视频内容的管理和标记变得越来越重要,无论是研究人员需要对实验视频进行时间点标记,还是个人用户希望对家庭视频进行... 目录引言1. 应用概述2. 技术栈分析2.1 核心库和模块2.2 wxpython作为GUI选择的优

Spring事务中@Transactional注解不生效的原因分析与解决

《Spring事务中@Transactional注解不生效的原因分析与解决》在Spring框架中,@Transactional注解是管理数据库事务的核心方式,本文将深入分析事务自调用的底层原理,解释为... 目录1. 引言2. 事务自调用问题重现2.1 示例代码2.2 问题现象3. 为什么事务自调用会失效3

mysql出现ERROR 2003 (HY000): Can‘t connect to MySQL server on ‘localhost‘ (10061)的解决方法

《mysql出现ERROR2003(HY000):Can‘tconnecttoMySQLserveron‘localhost‘(10061)的解决方法》本文主要介绍了mysql出现... 目录前言:第一步:第二步:第三步:总结:前言:当你想通过命令窗口想打开mysql时候发现提http://www.cpp

SpringBoot启动报错的11个高频问题排查与解决终极指南

《SpringBoot启动报错的11个高频问题排查与解决终极指南》这篇文章主要为大家详细介绍了SpringBoot启动报错的11个高频问题的排查与解决,文中的示例代码讲解详细,感兴趣的小伙伴可以了解一... 目录1. 依赖冲突:NoSuchMethodError 的终极解法2. Bean注入失败:No qu

使用Java实现通用树形结构构建工具类

《使用Java实现通用树形结构构建工具类》这篇文章主要为大家详细介绍了如何使用Java实现通用树形结构构建工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录完整代码一、设计思想与核心功能二、核心实现原理1. 数据结构准备阶段2. 循环依赖检测算法3. 树形结构构建4. 搜索子

springboot报错Invalid bound statement (not found)的解决

《springboot报错Invalidboundstatement(notfound)的解决》本文主要介绍了springboot报错Invalidboundstatement(not... 目录一. 问题描述二.解决问题三. 添加配置项 四.其他的解决方案4.1 Mapper 接口与 XML 文件不匹配

MySQL新增字段后Java实体未更新的潜在问题与解决方案

《MySQL新增字段后Java实体未更新的潜在问题与解决方案》在Java+MySQL的开发中,我们通常使用ORM框架来映射数据库表与Java对象,但有时候,数据库表结构变更(如新增字段)后,开发人员可... 目录引言1. 问题背景:数据库与 Java 实体不同步1.1 常见场景1.2 示例代码2. 不同操作

利用Python开发Markdown表格结构转换为Excel工具

《利用Python开发Markdown表格结构转换为Excel工具》在数据管理和文档编写过程中,我们经常使用Markdown来记录表格数据,但它没有Excel使用方便,所以本文将使用Python编写一... 目录1.完整代码2. 项目概述3. 代码解析3.1 依赖库3.2 GUI 设计3.3 解析 Mark