### 获取 Python 子进程返回值或通过 multiprocessing 模块共享数据 在 Python 中，`multiprocessing` 模块提供了多种方式来获取子进程的返回值或实现进程间的数据共享。以下是几种常见方法及其代码示例： #### 方法一：使用 `apply_async` 获取子进程返回值 通过 `apply_async` 方法可以异步执行任务，并且可以通过 `get()` 方法获取子进程的返回值[^2]。 ```python import multiprocessing def func(msg): return f"Result from {msg}" if __name__ == "__main__": pool = multiprocessing.Pool(processes=4) results = [] for i in range(10): msg = f"hello {i}" results.append(pool.apply_async(func, (msg, ))) # 异步调用函数 pool.close() # 关闭进程池 pool.join() # 等待所有进程完成 for res in results: print(res.get()) # 获取子进程返回值 ``` #### 方法二：使用 `map` 方法批量获取返回值 `map` 方法适用于将一个函数映射到可迭代对象上，并自动收集所有子进程的返回值[^4]。 ```python import multiprocessing def job(x): return x * x if __name__ == "__main__": pool = multiprocessing.Pool(processes=4) results = pool.map(job, range(20)) # 将 job 映射到 range(20) 上 print(results) # 打印所有子进程的返回值 ``` #### 方法三：使用共享内存（如 `Value` 或 `Array`） 如果需要在多个进程之间共享数据，可以使用 `multiprocessing` 提供的共享内存机制。例如，`Value` 和 `Array` 可以用于共享简单类型的数据[^1]。 ```python import multiprocessing def update_value(val): val.value += 1 if __name__ == "__main__": val = multiprocessing.Value('i', 0) # 创建一个共享整数 p = multiprocessing.Process(target=update_value, args=(val,)) p.start() p.join() print(f"Shared value: {val.value}") ``` #### 方法四：使用 `Manager` 创建更复杂的共享数据结构 对于更复杂的数据结构（如列表、字典等），可以使用 `Manager` 来创建可共享的对象[^1]。 ```python from multiprocessing import Process, Manager def add_to_list(lst, item): lst.append(item) if __name__ == "__main__": with Manager() as manager: shared_list = manager.list() # 创建一个共享列表 processes = [] for i in range(5): p = Process(target=add_to_list, args=(shared_list, i)) processes.append(p) p.start() for p in processes: p.join() print(f"Shared list: {shared_list}") ``` #### 方法五：通过队列（`Queue`）传递数据 `Queue` 是一种线程和进程安全的队列，可以在父进程和子进程之间传递数据[^1]。 ```python from multiprocessing import Process, Queue def worker(queue): queue.put("Data from child process") if __name__ == "__main__": q = Queue() p = Process(target=worker, args=(q,)) p.start() print(q.get()) # 从队列中获取子进程发送的数据 p.join() ``` ### 注意事项 - 如果父进程未正确处理子进程的状态（如调用 `join` 或 `close`），可能会导致僵尸进程问题[^3]。 - 在 Windows 系统上，必须将多进程相关代码放在 `if __name__ == "__main__":` 块中，否则可能引发异常。