Linux上使用Python 3.x的多处理生产者消费者

import multiprocessing

def producer(queue):
    # 生产者逻辑，向队列中放入数据
    data = [1, 2, 3, 4, 5]
    for item in data:
        queue.put(item)

def consumer(queue):
    # 消费者逻辑，从队列中取出数据并进行处理
    while True:
        item = queue.get()
        if item is None:
            break
        # 处理数据的逻辑
        print("Consumed:", item)

if __name__ == "__main__":
    # 创建一个队列用于生产者和消费者之间的数据传递
    queue = multiprocessing.Queue()

    # 创建生产者和消费者进程
    producer_process = multiprocessing.Process(target=producer, args=(queue,))
    consumer_process = multiprocessing.Process(target=consumer, args=(queue,))

    # 启动进程
    producer_process.start()
    consumer_process.start()

    # 等待生产者进程结束，并向队列中放入结束标志
    producer_process.join()
    queue.put(None)

    # 等待消费者进程结束
    consumer_process.join()