semaphore
信号量(Semaphore),有时被称为信号灯,是在多线程环境下使用的一种设施, 它负责协调各个线程, 以保证它们能够正确、合理的使用公共资源。
什么是信号量(Semaphore0
Semaphore分为单值和多值两种,前者只能被一个线程获得,后者可以被若干个线程获得。
以一个停车场是运作为例。为了简单起见,假设停车场只有三个车位,一开始三个车位都是空的。这是如果同时来了五辆车,看门人允许其中三辆不受阻碍的进入,然后放下车拦,剩下的车则必须在入口等待,此后来的车也都不得不在入口处等待。这时,有一辆车离开停车场,看门人得知后,打开车拦,放入一辆,如果又离开两辆,则又可以放入两辆,如此往复。
在这个停车场系统中,车位是公共资源,每辆车好比一个线程,看门人起的就是信号量的作用。
更进一步,信号量的特性如下:信号量是一个非负整数(车位数),所有通过它的线程(车辆)都会将该整数减一(通过它当然是为了使用资源),当该整数值为零时,所有试图通过它的线程都将处于等待状态。在信号量上我们定义两种操作: Wait(等待) 和 Release(释放)。 当一个线程调用Wait等待)操作时,它要么通过然后将信号量减一,要么一自等下去,直到信号量大于一或超时。Release(释放)实际上是在信号量上执行加操作,对应于车辆离开停车场,该操作之所以叫做“释放”是应为加操作实际上是释放了由信号量守护的资源。
实现
大家都知道,.Net Framework类库中提供的线程同步设施包括:
Monitor, AutoResetEvent, ManualResetEvent,Mutex,ReadWriteLock和 InterLock。 其中 AutoResetEvent, ManualResetEvent,Mutex派生自WaitHandler,它们实际上是封装了操作系统提供的内核对象。而其它的应当是在.Net虚拟机中土生土长的。显然来自操作系统内核对象的设施使用起来效率要差一些。不过效率并不是我们这里要考虑的问题,我们将使用两个 Monitor 和 一个ManualResetEvent 对象来模拟一个信号量。
代码如下:
public class Semaphore
{
private ManualResetEvent waitEvent = new ManualResetEvent(false);
private object syncObjWait = new object();
private int maxCount = 1; file://最大资源数
private int currentCount = 0; file://当前资源数
public Semaphore()
{
}
public Semaphore( int maxCount )
{
this.maxCount = maxCount;
}
public bool Wait()
{
lock( syncObjWait ) file://只能一个线程进入下面代码
{
bool waitResult = this.waitEvent.WaitOne(); file://在此等待资源数大于零
if( waitResult )
{
lock( this )
{
if( currentCount > 0 )
{
currentCount--;
if( currentCount == 0 )
{
this.waitEvent.Reset();
}
}
else
{
System.Diagnostics.Debug.Assert( false, "Semaphore is not allow current count < 0" );
}
}
}
return waitResult;
}
}
/**//// <summary>
/// 允许超时返回的 Wait 操作
/// </summary>
/// <param name="millisecondsTimeout"></param>
/// <returns></returns>
public bool Wait( int millisecondsTimeout )
{
lock( syncObjWait ) // Monitor 确保该范围类代码在临界区内
{
bool waitResult = this.waitEvent.WaitOne(millisecondsTimeout,false);
if( waitResult )
{
lock( this )
{
if( currentCount > 0 )
{
currentCount--;
if( currentCount == 0 )
{
this.waitEvent.Reset();
}
}
else
{
System.Diagnostics.Debug.Assert( false, "Semaphore is not allow current count < 0" );
}
}
}
return waitResult;
}
}
public bool Release()
{
lock( this ) // Monitor 确保该范围类代码在临界区内
{
currentCount++;
if( currentCount > this.maxCount )
{
currentCount = this.maxCount;
return false;
}
this.waitEvent.Set(); file://允许调用Wait的线程进入
}
return true;
}
}
分享到:
相关推荐
"MySQL Crash Course"是一本专为快速掌握MySQL核心概念和技术设计的教程,旨在帮助初学者和有一定基础的学习者迅速提升MySQL技能。 这本书的原版CHM格式提供了方便的电子阅读体验,CHM(Compiled HTML Help)是一种...
《MySQL必知必会》是数据库领域中一本非常经典的教程,尤其对于初学者而言,它提供了全面而实用的MySQL知识。MySQL是一种广泛使用的开源关系型数据库管理系统(RDBMS),在Web应用程序中扮演着核心角色。这本书以...
基于docker搭建的《MySQL Crash Course》学习实操环境
"MySQL Crash Course"通常指的是一个快速学习MySQL基础知识的教程,旨在帮助初学者迅速掌握其核心概念和操作。 1. **SQL基础**:SQL(Structured Query Language)是用于管理关系数据库的语言。学习MySQL首先要理解...
《MySQL Crash Course》是Ben Forta撰写的一本关于MySQL快速学习的书籍,由Sams Publishing在2005年出版。这本书旨在帮助读者在短时间内掌握MySQL数据库系统的基础知识和核心概念,适合初学者和需要快速了解MySQL的...
在本案例中,我们面临的是一个关于MySQL实例崩溃的问题,主要涉及MySQL 5.6.21版本。问题描述指出,生产环境中有多台MySQL服务器不定期地崩溃,但错误日志(error log)并未记录崩溃时的堆栈信息,只显示了重启过程。...
Sams.MySQL.Crash.Course.Dec.2005.chm
4. **Crash-safe**: Crash-safe 指的是系统在面临硬件故障或系统崩溃时,仍能保证数据的一致性和完整性。MySQL 5.7 的半同步复制(rpl_semi_sync)配合GTID,能在主库提交事务前等待至少一个从库确认收到事务,...
标题《MariaDB Crash Course (MySQL速成)》和描述表明这是一本专门为初学者编写的关于MariaDB的使用指南,同时也适用于希望快速掌握MySQL数据库技术的读者。本书强调的是其易于理解的条理性和入门级的适用性。标签...
Apache, MySQL, and PHP Weekend Crash Course.PDF
本文将探讨一种针对企业博客的MySQL 5.7数据库架构,该架构利用Global Transaction Identifier (GTID) 和 Multi-source Replication (MTS) 实现多级主从复制,并结合Crash safe策略确保数据一致性与高可用性。...
6、Making MySQL XA transactionprocessing crash safe 7、面向云原生架构的数据库引擎 8、云计算成本优化-大数据降本增效实战 9、瑞幸咖啡数据库平台与架构实践 10、MySQL HeatWave Lakehouse 11、分布式数据库必须...
"crashcourse"通常指的是快速学习课程,这个标签暗示了这是一个旨在短时间内快速掌握MySQL核心概念的教程。在描述中提到,原版的crashcourse脚本可能无法直接运行,因此进行了修改和补充,这意味着这个压缩包中的...
这本书的英文原版名为《MySQL Crash Course》,通过一系列实践性的例子和练习,让学习者能够深入理解数据库管理和SQL查询。配套源码包括了`populate.sql`和`create.sql`两个文件,它们在书中扮演着关键角色,用于...
`mysql crash course script (chapter03-17)` 和 `mysql crash course script (chapter18-29)` 文件名暗示了它们是书中各章节的配套练习或示例脚本。这些SQL脚本可能是书中的练习解决方案,帮助读者实践和巩固书...
6、Making MySQL XA transactionprocessing crash safe 7、面向云原生架构的数据库引擎 8、云计算成本优化-大数据降本增效实战 9、瑞幸咖啡数据库平台与架构实践 10、MySQL HeatWave Lakehouse 11、分布式数据库必须...
MySQL crash指的是数据库进程崩溃,这通常是由于数据库的Bug、硬件故障或内存不足等原因引起的。主机Hung指的是数据库所在的服务器响应缓慢或无响应,这时需要检查服务器整体状态和资源使用情况。 为了诊断MySQL...
MySQL Crash Course, 2nd Edition 检索和排序数据 使用比较、正则表达式、全文搜索等过滤数据 连接关系数据 创建和更改表 插入、更新和删除数据 利用存储过程和触发器的强大功能 使用视图和游标 管理事务处理 创建...
- **崩溃恢复启动**:“Starting crash recovery.”,MySQL尝试进行崩溃恢复。 - **表空间读取**:“Reading tablespace information from the .ibd files...”,系统正在扫描所有.ibd文件来获取表空间信息。 - *...