生产者消费者问题是一个经典的多线程同步问题，在 Python 中有多种实现方式。 ### 使用 `threading` 和 `queue` 模块实现 某些模块负责生产数据，这些数据由其他模块来负责处理（此处的模块可能是：函数、线程、进程等），产生数据的模块称为生产者，而处理数据的模块称为消费者，在生产者与消费者之间的缓冲区称之为仓库，生产者负责往仓库运输商品，而消费者负责从仓库里取出商品，这就构成了生产者消费者模式 [^2]。 以下是一个简单的示例代码： ```python import threading import queue import time import random def producer(q): while True: data = random.randint(0, 100) q.put(data) print(f"Produced {data}") time.sleep(random.random()) def consumer(q): while True: data = q.get() print(f"Consumed {data}") q.task_done() time.sleep(random.random()) if __name__ == "__main__": q = queue.Queue() producer_thread = threading.Thread(target=producer, args=(q,)) consumer_thread = threading.Thread(target=consumer, args=(q,)) producer_thread.start() consumer_thread.start() producer_thread.join() consumer_thread.join() ``` ### 使用 `multiprocessing` 模块实现 `multiprocessing` 模块可以实现多进程的生产者消费者模式，示例代码如下： ```python from multiprocessing import Process, Queue import time import random def producer(q): while True: data = random.randint(0, 100) q.put(data) print(f"Produced {data}") time.sleep(random.random()) def consumer(q): while True: data = q.get() print(f"Consumed {data}") time.sleep(random.random()) if __name__ == "__main__": q = Queue() producer_process = Process(target=producer, args=(q,)) consumer_process = Process(target=consumer, args=(q,)) producer_process.start() consumer_process.start() producer_process.join() consumer_process.join() ``` 另外，还可以使用 `concurrent.futures` 模块来解决该问题，不过代码未给出示例 [^5]。