python多进程pool并行多个子进程并用pipe获取返回值

可以使用多进程池（`Pool`）并行执行多个子进程，并使用 `pipe` 获取它们的返回值。以下是一个示例代码：

import multiprocessing

def worker(num):
    """进程执行的函数"""
    result = num * 2
    return result

if __name__ == '__main__':
    # 创建管道
    parent_conn, child_conn = multiprocessing.Pipe()
    # 创建进程池
    pool = multiprocessing.Pool()
    # 提交多个进程任务
    results = [pool.apply_async(worker, args=(i,)) for i in range(5)]
    # 关闭进程池
    pool.close()
    pool.join()
    # 获取进程返回值
    for result in results:
        parent_conn.send(result.get())
    parent_conn.close()
    print([child_conn.recv() for _ in range(len(results))])

在上面的示例代码中，我们创建了一个管道，使用 `Pipe` 函数返回了两个连接对象：`parent_conn` 和 `child_conn`。在进程池中，我们使用 `apply_async` 方法异步地提交多个进程任务，并使用列表 `results` 存储异步任务的返回值。在主进程中，我们使用循环遍历 `results`，将进程返回值发送到管道中，并使用循环接收管道中的数据，最终打印出所有进程的返回值。

需要注意的是，在使用多进程池时，必须先关闭进程池，然后调用 `join` 方法等待所有进程结束。否则，主进程将会一直等待，直到所有进程都执行完成。另外，由于 `Pipe` 是双向连接，因此在发送数据和接收数据时，需要分别使用不同的连接对象。