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

除了使用全局变量外，Python中的队列（Queue）也是一种很好的线程间通信机制。队列可以用来实现生产者消费者模型，其中生产者线程向队列中添加数据，消费者线程从队列中取出数据进行处理。Python中的Queue模块提供了多种队列类型，包括FIFO队列、LIFO队列和优先队列等。

下面的示例展示了如何使用队列实现生产者消费者模型：

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

在上面的示例中，我们定义了一个队列q，生产者线程会向队列中添加数据，消费者线程会从队列中取出数据进行处理。通过使用队列，我们可以实现线程之间的协作和通信，而不必担心数据共享的问题。

声明：本文内容由网友自发贡献，本站不承担相应法律责任。对本内容有异议或投诉，请联系2913721942#qq.com核实处理，我们将尽快回复您，谢谢合作！