python高级线程编程-线程间通信（三）

import threading

# 条件变量
cond = threading.Condition()

# 共享数据
buffer = []

# 生产者线程函数
def producer():
    for i in range(5):
        with cond:
            item = "Item {}".format(i)
            buffer.append(item)
            print("Produced {}".format(item))
            cond.notifyAll()

# 消费者线程函数
def consumer():
    while True:
        with cond:
            if len(buffer) == 0:
                cond.wait()
            item = buffer.pop(0)
            if item is None:
                break
            print("Consumed {}".format(item))

# 创建生产者和消费者线程
t1 = threading.Thread(target=producer)
t2 = threading.Thread(target=consumer)

# 启动线程
t1.start()
t2.start()

# 等待生产者线程结束
t1.join()

# 停止消费者线程
with cond:
    buffer.append(None)
    cond.notifyAll()
t2.join()