multiprocessing.Process 父进程如何 实时获取子进程的数据

在Python的`multiprocessing`模块中，有多种方法可以实现父进程实时获取子进程的数据，以下是两种常用的方法：

1. 使用`multiprocessing.Pipe`进行进程间通信。在子进程中，你可以将数据写入管道中；在父进程中，你可以实时读取管道中的数据。以下是一个示例代码：

from multiprocessing import Process, Pipe

def child_process(conn):
    for i in range(10):
        conn.send(f"Message {i} from child process")
    conn.close()

if __name__ == "__main__":
    parent_conn, child_conn = Pipe()
    p = Process(target=child_process, args=(child_conn,))
    p.start()

    while True:
        if parent_conn.poll():  # 检查管道是否有数据
            message = parent_conn.recv()  # 读取管道中的数据
            print(f"Received message in parent process: {message}")
        if not p.is_alive():  # 如果子进程已经结束，退出循环
            break

    p.join()

2. 使用`multiprocessing.Queue`进行进程间通信。在子进程中，你可以将数据加入队列中；在父进程中，你可以实时从队列中读取数据。以下是一个示例代码：

from multiprocessing import Process, Queue

def child_process(q):
    for i in range(10):
        q.put(f"Message {i} from child process")

if __name__ == "__main__":
    q = Queue()
    p = Process(target=child_process, args=(q,))
    p.start()

    while True:
        if not q.empty():  # 检查队列是否有数据
            message = q.get()  # 从队列中读取数据
            print(f"Received message in parent process: {message}")
        if not p.is_alive():  # 如果子进程已经结束，退出循环
            break

    p.join()

需要注意的是，以上两种方法都需要在父进程中使用循环实时获取子进程的数据，并且在父进程中需要判断子进程是否已经结束。