### Python进程间通信方法 在Python中，进程间通信（Inter-Process Communication, IPC）可以通过多种方式实现。以下是几种常见的方法及其特点： #### 1. **Pipe** Pipe是一种简单的进程间通信机制，允许两个进程之间通过管道进行数据交换。Python中的`multiprocessing.Pipe`提供了类似功能，但其使用方式更接近于socket[^1]。 ```python from multiprocessing import Pipe, Process def sender(conn): conn.send("Hello from sender") conn.close() def receiver(conn): msg = conn.recv() print(f"Received: {msg}") if __name__ == "__main__": parent_conn, child_conn = Pipe() p1 = Process(target=sender, args=(child_conn,)) p2 = Process(target=receiver, args=(parent_conn,)) p1.start() p2.start() p1.join() p2.join() ``` 上述代码展示了如何使用`Pipe`在两个进程之间传递消息。 #### 2. **Socket** Socket是一种更为通用的进程间通信机制，支持跨机器的进程间通信。它最初由Unix系统的BSD分支开发，现已广泛应用于各种操作系统[^3]。 ```python import socket # 服务器端 server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) server_socket.bind(("localhost", 9999)) server_socket.listen(1) conn, addr = server_socket.accept() data = conn.recv(1024) print(f"Received: {data.decode()}") conn.close() # 客户端 client_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM) client_socket.connect(("localhost", 9999)) client_socket.send(b"Hello from client") client_socket.close() ``` 此示例展示了如何通过Socket在两个程序之间进行通信。 #### 3. **Queue** `multiprocessing.Queue`提供了一种线程安全和进程安全的方式来进行数据交换，适用于多进程环境下的任务队列管理[^2]。 ```python from multiprocessing import Queue, Process def producer(queue): for i in range(5): queue.put(f"Message {i}") queue.put(None) # 停止信号 def consumer(queue): while True: msg = queue.get() if msg is None: break print(f"Consumed: {msg}") if __name__ == "__main__": queue = Queue() p1 = Process(target=producer, args=(queue,)) p2 = Process(target=consumer, args=(queue,)) p1.start() p2.start() p1.join() p2.join() ``` #### 4. **Shared Memory** 共享内存是一种高效的进程间通信方式，允许多个进程直接访问同一块内存区域。Python 3.8及以上版本引入了`multiprocessing.shared_memory`模块来支持这一功能。 ```python from multiprocessing import shared_memory, Process def writer(): shm = shared_memory.SharedMemory(name="my_shm", create=True, size=100) shm.buf[:5] = bytearray("Hello", "utf-8") shm.close() def reader(): shm = shared_memory.SharedMemory(name="my_shm") print(f"Read: {shm.buf[:5].tobytes().decode()}") shm.close() shm.unlink() if __name__ == "__main__": p1 = Process(target=writer) p2 = Process(target=reader) p1.start() p2.start() p1.join() p2.join() ``` ### 总结 不同的进程间通信方式适用于不同的场景：`Pipe`适合简单的父子进程通信；`Socket`适合跨机器或复杂网络环境下的通信；`Queue`适合任务队列管理；而`Shared Memory`则适合需要高性能的数据共享场景。