线程条件变量：未获得的锁

Question

我在 Python 中有这个示例，它演示了条件变量的使用。

import logging
import threading
import time

logging.basicConfig(level=logging.DEBUG, format='%(asctime)s (%(threadName)-2s) %(message)s',)

def consumer(cond):

    # wait for the condition and use the resource

    logging.debug('Starting consumer thread')

    t = threading.currentThread()

    cond.wait()

    logging.debug('Resource is available to consumer')

def producer(cond):

    # set up the resource to be used by the consumer

    logging.debug('Starting producer thread')

    logging.debug('Making resource available')

    cond.notifyAll()


condition = threading.Condition()

# pass each thread a 'condition'
c1 = threading.Thread(name='c1', target=consumer, args=(condition,))
c2 = threading.Thread(name='c2', target=consumer, args=(condition,))
p = threading.Thread(name='p', target=producer, args=(condition,))


# start two threads and put them into 'wait' state
c1.start()
c2.start()

# after two seconds or after some operation notify them to free or step over the wait() function
time.sleep(2)
p.start()

但是，它会在线程上引发运行时错误un-acquired lock。我有一个想法，我需要使用 acquire 和 release 函数，但我不确定它们的用法以及它们的作用。

Answer 1

条件是底层Lock 的包装器，提供等待/通知功能。您需要 acquire 一个锁才能释放它 - wait 在后台执行此操作。值得注意的是，一旦它被重新唤醒，它重新获取锁。因此，在获取和释放之间确保互斥，如果有意义的话，wait “yielding” 对锁的控制。

无需手动进行获取/释放，只需使用 Condition 作为上下文管理器：

def consumer(cond):
    with cond:
        cond.wait()

    logging.debug('Resource is available to consumer')

如果由于某种原因你被困在没有上下文管理器的 python 版本上，这相当于：

def consumer(cond):
    try:
        cond.acquire()
        cond.wait()
    finally:
        cond.release()

    logging.debug('Resource is available to consumer')

您通常希望确保只有一个消费者被唤醒，因此经常使用以下成语：

with cond:
    while some_queue.isEmpty():
        cond.wait()
    #get one from queue

因此，您可以notify 任意数量的消费者，一旦队列为空，额外的消费者会立即返回睡眠状态。