在Python中，我们可以使用`multiprocessing`库创建进程以及`Queue`（也叫作`multiprocessing.Queue`）来实现这个功能。这里是一个简单的示例： ```python import multiprocessing # 创建消息队列 message_queue = multiprocessing.Queue() def send_message(message): print(f"Process A sending message: {message}") message_queue.put(message) def read_and_print(queue): while True: try: message = queue.get() if message == "STOP": break print(f"Process B received and printed: {message}") except Exception as e: print(f"Error occurred: {e}") def send_name(name): print(f"Process C sending name: {name}") message_queue.put(name) def fetch_and_print_name(queue): while True: try: name = queue.get() if name == "STOP": break print(f"Process D fetched and printed name: {name}") except Exception as e: print(f"Error occurred fetching name: {e}") # 启动进程 process_a = multiprocessing.Process(target=send_message, args=("hello, world",)) process_b = multiprocessing.Process(target=read_and_print, args=(message_queue,)) process_c = multiprocessing.Process(target=send_name, args=("我自己",)) process_d = multiprocessing.Process(target=fetch_and_print_name, args=(message_queue,)) # 开始并等待所有进程结束 process_a.start() process_b.start() process_c.start() process_d.start() # 停止信号 message_queue.put("STOP") # 等待所有进程结束 for process in [process_a, process_b, process_c, process_d]: process.join() print("All processes finished.") ``` 在这个例子中，我们创建了四个进程，分别负责发送消息、接收并打印消息、发送姓名和接收并打印姓名。当所有的信息发送完毕后，我们在消息队列中放入一个停止信号（这里是"STOP"），然后让各个进程退出。