python - 线程条件变量 : un-acquired lock

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 的包装器。您需要先获取 一个锁，然后才能释放它 - wait 在后台执行此操作。值得注意的是，一旦它被重新唤醒，它就会重新获取锁。因此，在获取和释放之间确保了互斥，如果有意义的话，wait“让出”锁的控制权。

与其手动获取/释放，不如使用 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

因此，您可以通知任意数量的消费者，一旦队列为空，多余的消费者就立即返回休眠状态。