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

相关文章

linux报错INFO:task xxxxxx:634 blocked for more than 120 seconds.三种解决方式

《linux报错INFO:taskxxxxxx:634blockedformorethan120seconds.三种解决方式》文章描述了一个Linux最小系统运行时出现的“hung_ta... 目录1.问题描述2.解决办法2.1 缩小文件系统缓存大小2.2 修改系统IO调度策略2.3 取消120秒时间限制3

java图像识别工具类(ImageRecognitionUtils)使用实例详解

《java图像识别工具类(ImageRecognitionUtils)使用实例详解》:本文主要介绍如何在Java中使用OpenCV进行图像识别,包括图像加载、预处理、分类、人脸检测和特征提取等步骤... 目录前言1. 图像识别的背景与作用2. 设计目标3. 项目依赖4. 设计与实现 ImageRecogni

关于@MapperScan和@ComponentScan的使用问题

《关于@MapperScan和@ComponentScan的使用问题》文章介绍了在使用`@MapperScan`和`@ComponentScan`时可能会遇到的包扫描冲突问题,并提供了解决方法,同时,... 目录@MapperScan和@ComponentScan的使用问题报错如下原因解决办法课外拓展总结@

MybatisGenerator文件生成不出对应文件的问题

《MybatisGenerator文件生成不出对应文件的问题》本文介绍了使用MybatisGenerator生成文件时遇到的问题及解决方法,主要步骤包括检查目标表是否存在、是否能连接到数据库、配置生成... 目录MyBATisGenerator 文件生成不出对应文件先在项目结构里引入“targetProje

C#使用HttpClient进行Post请求出现超时问题的解决及优化

《C#使用HttpClient进行Post请求出现超时问题的解决及优化》最近我的控制台程序发现有时候总是出现请求超时等问题,通常好几分钟最多只有3-4个请求,在使用apipost发现并发10个5分钟也... 目录优化结论单例HttpClient连接池耗尽和并发并发异步最终优化后优化结论我直接上优化结论吧,

Java内存泄漏问题的排查、优化与最佳实践

《Java内存泄漏问题的排查、优化与最佳实践》在Java开发中,内存泄漏是一个常见且令人头疼的问题,内存泄漏指的是程序在运行过程中,已经不再使用的对象没有被及时释放,从而导致内存占用不断增加,最终... 目录引言1. 什么是内存泄漏?常见的内存泄漏情况2. 如何排查 Java 中的内存泄漏?2.1 使用 J

基于Python开发电脑定时关机工具

《基于Python开发电脑定时关机工具》这篇文章主要为大家详细介绍了如何基于Python开发一个电脑定时关机工具,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录1. 简介2. 运行效果3. 相关源码1. 简介这个程序就像一个“忠实的管家”,帮你按时关掉电脑,而且全程不需要你多做

numpy求解线性代数相关问题

《numpy求解线性代数相关问题》本文主要介绍了numpy求解线性代数相关问题,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 在numpy中有numpy.array类型和numpy.mat类型,前者是数组类型,后者是矩阵类型。数组

解决systemctl reload nginx重启Nginx服务报错:Job for nginx.service invalid问题

《解决systemctlreloadnginx重启Nginx服务报错:Jobfornginx.serviceinvalid问题》文章描述了通过`systemctlstatusnginx.se... 目录systemctl reload nginx重启Nginx服务报错:Job for nginx.javas

基于C#实现PDF文件合并工具

《基于C#实现PDF文件合并工具》这篇文章主要为大家详细介绍了如何基于C#实现一个简单的PDF文件合并工具,文中的示例代码简洁易懂,有需要的小伙伴可以跟随小编一起学习一下... 界面主要用于发票PDF文件的合并。经常出差要报销的很有用。代码using System;using System.Col