多进程协作困惑：Python如何实现多个进程间安全通信？

原创墨蓝 2025-03-18 02:57 30阅读 0赞

在Python中，可以使用多种方式来实现多个进程间的安全通信。这里以常用的两种方法进行介绍：

1. **使用`multiprocessing.Queue`**：
   `Queue`是`multiprocessing`模块中的一个类，主要用于进程间的消息传递。

例如：
   ```python
   from multiprocessing import Queue

# 创建一个消息队列
   message_queue = Queue()

# 进程A：将消息加入队列并发送出去
   def process_A(msg):
       message_queue.put(msg)  # 将消息放入队列
       print(f"A已发送消息: {msg}")  # 发送消息

# 进程B：从队列中获取消息进行处理
   def process_B():
       while not message_queue.empty():  # 检查队列是否为空
           msg = message_queue.get()  # 获取队列中的消息
           print(f"B已接收到消息: {msg}")  # 处理并打印消息

# 启动两个进程
   process_A("Hello from Process A!")
   process_B()
   ```
   在这段代码中，`process_A`将信息发送到队列，而`process_B`则从队列中获取信息进行处理。

2. **使用`multiprocessing.Pipe`**：
   `Pipe`是`multiprocessing`模块中的一个类，用于创建两个进程间双向通信的管道。

例如：
   ```python
   from multiprocessing import Pipe

# 创建管道
   parent_conn, child_conn = Pipe()

# 进程A：将消息发送到管道，然后等待子进程接收消息
   def process_A(msg):
       child_conn.send(msg)  # 将消息发送至管道
       print(f"A已发送消息: {msg}")  # 发送消息

# 等待子进程接收到消息并处理
       response = parent_conn.recv()
       print(f"A已收到子进程的响应: {response}")  # 接收响应并打印

# 进程B：从管道中接收消息进行处理
   def process_B():
       msg = child_conn.recv()  # 等待子进程发送消息
       print(f"B已接收到消息: {msg}")  # 接收并打印消息

# 启动两个进程
   process_A("Hello from Process A!")
   process_B()
   ```
   在这段代码中，`process_A`向管道发送信息，并等待子进程接收信息。而`process_B`则从管道中接收信息进行处理。

这两种方式都可以实现多个进程间的安全通信。你可以根据实际需求选择合适的方法。