在 Python 中实现两个子进程之间的通信，通常可以使用 `multiprocessing` 模块提供的几种机制来完成。其中最常见的方式是使用 `Queue` 和 `Pipe`。 ### 使用 Queue 实现进程间通信 `Queue` 是一种线程和进程安全的队列实现，非常适合用于在多个进程之间传递数据。它支持多个生产者和消费者，并且可以在不同的进程中共享。 下面是一个简单的例子，展示如何通过 `Queue` 在两个子进程之间进行通信： ```python from multiprocessing import Process, Queue def writer(queue): queue.put("Hello from writer process") def reader(queue): message = queue.get() print(f"Reader received: {message}") if __name__ == '__main__': # 创建一个队列对象 mq = Queue() # 创建两个进程 pw = Process(target=writer, args=(mq,)) pr = Process(target=reader, args=(mq,)) # 启动写入进程 pw.start() # 启动读取进程 pr.start() # 等待两个进程完成 pw.join() pr.join() ``` 在这个示例中，`writer` 函数向队列中放入一条消息，而 `reader` 函数从队列中取出这条消息并打印出来[^4]。 ### 使用 Pipe 实现进程间通信 `Pipe` 提供了一种更为直接的方式来在两个进程之间进行双向通信。每个管道由两个连接端组成，每端都可以发送和接收数据。 以下是如何使用 `Pipe` 的示例代码： ```python from multiprocessing import Process, Pipe def sender(conn): conn.send(["Hello", "World"]) # 发送数据 conn.close() # 关闭连接 def receiver(conn): received_data = conn.recv() # 接收数据 print(f"Received data: {received_data}") conn.close() # 关闭连接 if __name__ == '__main__': parent_conn, child_conn = Pipe() # 创建一对连接对象 # 创建发送进程 ps = Process(target=sender, args=(parent_conn,)) # 创建接收进程 pr = Process(target=receiver, args=(child_conn,)) # 启动发送进程 ps.start() # 启动接收进程 pr.start() # 等待两个进程完成 ps.join() pr.join() ``` 在这个例子中，`sender` 函数通过管道的一端发送了一个列表，而 `receiver` 函数则通过另一端接收这个列表并打印其内容[^1]。 ### 总结 - **Queue** 更适合于需要处理多个生产者和消费者的场景。 - **Pipe** 更适用于两个进程间的点对点通信，尤其是当需要更高效的传输性能时。 这两种方法都能够有效地帮助你在 Python 中构建多进程应用程序，并确保它们能够相互通信。