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

import threading
import queue

# 队列
q = queue.Queue()

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

# 消费者线程函数
def consumer():
    while True:
        item = q.get()
        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()

# 停止消费者线程
q.put(None)
t2.join()