监视器同步：实现多个条件变量

Question

我正在实施监视器同步。我想知道实现多个条件变量是如何工作的。 因此，条件变量具有 wait() 方法，该方法将其放入与该条件变量绑定的特定锁的等待队列中。因此，如果我有多个条件变量，每个等待调用是否都会创建自己单独的等待队列？ 例如，如果我有：

lock = Lock()  
A = Condition(lock)  
B = Condition(lock)  
C = Condition(lock)  

def foo:  
     with lock:  
        while true:  
            A.wait()  

def bar:  
    with lock:  
        while true:  
            B.wait()  

def notifyA  
    with lock:  
        A.notifyAll()  

那么我的问题是，当我们执行 A.notifyAll() 时，它是否只唤醒 A.wait 队列中的内容，或者有一个与锁关联的组合队列。

Answer 1

A.notifyAll() 应该只唤醒运行 foo() 的线程。您的线程wait()所在的等待队列是条件变量的一部分，而不是锁的一部分。锁确实有自己的等待队列，但它仅由尝试获取锁的线程使用。当您的线程在 CV 中休眠时，它不会持有锁，并且不会尝试重新获取锁，直到另一个线程调用 notify() 或类似的方法。

也就是说，您应该编写代码来假设 B.wait() 实际上可以随时唤醒。实际上，这意味着重新检查线程正在等待的条件：

    with lock:
        while not ready:
            B.wait()
        # Do stuff with protected data