并发与底层机制:SML/NJ 深入解析
1. 并发中的信号量
在并发编程中,信号量是一种重要的同步机制。这里介绍了使用同步变量(M - 变量)实现信号量的替代方法,这种实现更接近 Java 等语言的传统实现,多个线程作为对等体合作以保证临界区的安全,与依赖中央管理线程的实现形成对比。
1.1 互斥锁(Mutex)
互斥锁是一种特殊的二元信号量,其计数只能是 0 或 1,用于保护临界区代码,确保同一时间只有一个线程能执行该代码。以下是使用 M - 变量实现互斥锁的代码:
structure Mutex: MUTEX = struct structure SV = SyncVar type Mutex = bool SV.mvar fun create() = SV.mVarInit true fun lock mutex func = ( SV.mTake mutex; let val r = func() in SV.mPut(mutex, true); r end handle x => ( SV.mPut(mutex, true); raise x ) ) end当一个线程调用lock函数时,它会尝试从互斥锁中取出值。如果成功,就可以继续运行传入的函数,运行结束后将值放回互斥锁以释放锁。如果传入的函数