python生产消费模式

Python生产消费模式是指多个生产者一起生产，多个消费者一起消费的一种模式。它让程序设计更加灵活，可以同时处理多个任务，提高程序执行效率。

在Python中，可以使用队列来实现生产消费模式。队列就像一条传送带，生产者把产品放到队列的尾部，消费者从队列的头部拿出产品进行消费。当队列中没有产品时，消费者就会阻塞等待，直到队列中有产品为止。

import threading
import queue
import time

class Producer(threading.Thread):
    def __init__(self,queue):
        threading.Thread.__init__(self)
        self.queue = queue

    def run(self):
        for i in range(10):
            product = "Product " + str(i)
            time.sleep(1)
            self.queue.put(product)
            print("Producer put " + product)

class Consumer(threading.Thread):
    def __init__(self,queue):
        threading.Thread.__init__(self)
        self.queue = queue

    def run(self):
        while True:
            product = self.queue.get()
            time.sleep(2)
            print("Consumer get " + product)

if __name__ == '__main__':
    q = queue.Queue()
    producer = Producer(q)
    consumer1 = Consumer(q)
    consumer2 = Consumer(q)

    producer.start()
    consumer1.start()
    consumer2.start()

    producer.join()
    consumer1.join()
    consumer2.join()

在这个例子中，我们启动了一个生产者和两个消费者，并且使用队列存储产品。生产者每隔一秒生产一个产品，并把产品放到队列中。消费者从队列中获取产品，并且每隔两秒消费一个产品。当队列为空时，消费者会被阻塞等待新的产品。

Python的生产消费模式可以应用于很多场景，比如多线程下载文件、多进程爬虫、消息队列等。它是一种高效且可靠的程序设计模式，值得我们学习和应用。