Condition类

前情提要：

顾名思义，Condition通过某些条件实现对线程的调度。其调用过程用到notify()和acquire()这两组函数。前者表示通知各个有acquire的线程，你们开始执行吧；后者则表示取得某个执行权（即取到锁的钥匙）。

继续考虑大象和冰箱的关系，如果现在有一家饭店专门做大象肉，所以当冰箱装到足够数量的大象的时候，饭店会一次性取走一半。

那么现在假设有2个大冰箱，每个冰箱能装好多个大象，饭店则每次取走5个。

from threading import Condition, Thread
import time

con = Condition()
fridges = 0    #现在冰箱里一只大象都没

# 把大象装冰箱
def e2f(name):
    global fridges
    while True:
        # 如果acquire未收到通知，则继续循环
        if not con.acquire():
            continue
        # 已经装满了10个冰箱的时候，就不要再装了
        if fridges >= 10:
            print("饭店来取大象吧")
            con.wait()
        else:
            fridges += 1
            print(name, f"装了一个大象，现在总共有{fridges}个大象")
            # 从waiting池中挑选一个线程，通知其调用acquire方法尝试取到锁
            con.notify()
        con.release()
        time.sleep(1)

# 从冰箱到饭店
def f2r(name):
    global fridges
    while True:
        if not con.acquire():
            continue
        if fridges < 10:
            con.wait()
        else:
            fridges -= 5
            print(name, f'取走了5个大象，现在冰箱里还有{fridges}个')
            con.notify()
        con.release()
        time.sleep(1)

def test():
    for i in range(2):
        Thread(target=e2f,args=[f"冰箱{i}"],daemon=True).start()
    for i in range(5):
        Thread(target=f2r,args=[f"饭店{i}"],daemon=True).start()

其运行结果为

>>> test()
冰箱0 装了一个大象，现在总共有1个大象
冰箱1 装了一个大象，现在总共有2个大象
冰箱0 装了一个大象，现在总共有3个大象
冰箱1 装了一个大象，现在总共有4个大象
冰箱1 装了一个大象，现在总共有5个大象
冰箱0 装了一个大象，现在总共有6个大象
冰箱1 装了一个大象，现在总共有7个大象
冰箱0 装了一个大象，现在总共有8个大象
冰箱1 装了一个大象，现在总共有9个大象
冰箱0 装了一个大象，现在总共有10个大象
饭店0 取走了5个大象，现在冰箱里还有5个
冰箱1 装了一个大象，现在总共有6个大象
冰箱0 装了一个大象，现在总共有7个大象
冰箱1 装了一个大象，现在总共有8个大象
冰箱0 装了一个大象，现在总共有9个大象
冰箱0 装了一个大象，现在总共有10个大象
饭店来取大象吧
...