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

相关文章

SQLite3命令行工具最佳实践指南

《SQLite3命令行工具最佳实践指南》SQLite3是轻量级嵌入式数据库,无需服务器支持,具备ACID事务与跨平台特性,适用于小型项目和学习,sqlite3.exe作为命令行工具,支持SQL执行、数... 目录1. SQLite3简介和特点2. sqlite3.exe使用概述2.1 sqlite3.exe

qt5cored.dll报错怎么解决? 电脑qt5cored.dll文件丢失修复技巧

《qt5cored.dll报错怎么解决?电脑qt5cored.dll文件丢失修复技巧》在进行软件安装或运行程序时,有时会遇到由于找不到qt5core.dll,无法继续执行代码,这个问题可能是由于该文... 遇到qt5cored.dll文件错误时,可能会导致基于 Qt 开发的应用程序无法正常运行或启动。这种错

基于Python实现一个Windows Tree命令工具

《基于Python实现一个WindowsTree命令工具》今天想要在Windows平台的CMD命令终端窗口中使用像Linux下的tree命令,打印一下目录结构层级树,然而还真有tree命令,但是发现... 目录引言实现代码使用说明可用选项示例用法功能特点添加到环境变量方法一:创建批处理文件并添加到PATH1

SpringBoot排查和解决JSON解析错误(400 Bad Request)的方法

《SpringBoot排查和解决JSON解析错误(400BadRequest)的方法》在开发SpringBootRESTfulAPI时,客户端与服务端的数据交互通常使用JSON格式,然而,JSON... 目录问题背景1. 问题描述2. 错误分析解决方案1. 手动重新输入jsON2. 使用工具清理JSON3.

使用jenv工具管理多个JDK版本的方法步骤

《使用jenv工具管理多个JDK版本的方法步骤》jenv是一个开源的Java环境管理工具,旨在帮助开发者在同一台机器上轻松管理和切换多个Java版本,:本文主要介绍使用jenv工具管理多个JD... 目录一、jenv到底是干啥的?二、jenv的核心功能(一)管理多个Java版本(二)支持插件扩展(三)环境隔

MySQL 设置AUTO_INCREMENT 无效的问题解决

《MySQL设置AUTO_INCREMENT无效的问题解决》本文主要介绍了MySQL设置AUTO_INCREMENT无效的问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参... 目录快速设置mysql的auto_increment参数一、修改 AUTO_INCREMENT 的值。

关于跨域无效的问题及解决(java后端方案)

《关于跨域无效的问题及解决(java后端方案)》:本文主要介绍关于跨域无效的问题及解决(java后端方案),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录通用后端跨域方法1、@CrossOrigin 注解2、springboot2.0 实现WebMvcConfig

Go语言中泄漏缓冲区的问题解决

《Go语言中泄漏缓冲区的问题解决》缓冲区是一种常见的数据结构,常被用于在不同的并发单元之间传递数据,然而,若缓冲区使用不当,就可能引发泄漏缓冲区问题,本文就来介绍一下问题的解决,感兴趣的可以了解一下... 目录引言泄漏缓冲区的基本概念代码示例:泄漏缓冲区的产生项目场景:Web 服务器中的请求缓冲场景描述代码

Python使用smtplib库开发一个邮件自动发送工具

《Python使用smtplib库开发一个邮件自动发送工具》在现代软件开发中,自动化邮件发送是一个非常实用的功能,无论是系统通知、营销邮件、还是日常工作报告,Python的smtplib库都能帮助我们... 目录代码实现与知识点解析1. 导入必要的库2. 配置邮件服务器参数3. 创建邮件发送类4. 实现邮件

Java死锁问题解决方案及示例详解

《Java死锁问题解决方案及示例详解》死锁是指两个或多个线程因争夺资源而相互等待,导致所有线程都无法继续执行的一种状态,本文给大家详细介绍了Java死锁问题解决方案详解及实践样例,需要的朋友可以参考下... 目录1、简述死锁的四个必要条件:2、死锁示例代码3、如何检测死锁?3.1 使用 jstack3.2