admin管理员组

文章数量:1599543

文章目录

  • Condition类

最新整合版：Python多线程详解
前情提要：

  1. Thread类初步
  2. 多个线程一起执行
  3. 把多个大象装进多个冰箱

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()

其运行结果为

冰箱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个大象
饭店来取大象吧

本文标签： 多线程Pythoncondition

版权声明：本文标题：【Python多线程】4：Condition类 内容由热心网友自发贡献，该文观点仅代表作者本人， 转载请联系作者并注明出处：https://m.elefans.com/dianzi/1728321337a1153861.html， 本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌抄袭侵权/违法违规的内容，一经查实，本站将立刻删除。