用python写一个三个进程之间用管道通信的例子

好的，下面是一个使用Python的multiprocessing模块实现三个进程之间用管道通信的例子：

import multiprocessing

def process1(conn):
    conn.send('Hello from Process 1')
    print('Process 1 sent message')

def process2(conn1, conn2):
    msg = conn1.recv()
    print('Process 2 received message: ', msg)
    conn2.send('Hello from Process 2')
    print('Process 2 sent message')

def process3(conn):
    msg = conn.recv()
    print('Process 3 received message: ', msg)

if __name__ == '__main__':
    # 创建两个管道
    conn1, conn2 = multiprocessing.Pipe()
    conn2, conn3 = multiprocessing.Pipe()
    # 创建三个进程并启动它们
    p1 = multiprocessing.Process(target=process1, args=(conn1,))
    p2 = multiprocessing.Process(target=process2, args=(conn1, conn2))
    p3 = multiprocessing.Process(target=process3, args=(conn3,))
    p1.start()
    p2.start()
    p3.start()
    # 等待进程结束
    p1.join()
    p2.join()
    p3.join()

在该示例中，我们创建了两个管道并分别传递给了三个进程。进程1向管道1发送消息，进程2从管道1接收消息并向管道2发送消息，进程3从管道2接收消息。最终，我们使用join()方法等待所有进程结束。

需要注意的是，管道传输的数据必须是可序列化的，否则会出现错误。在该示例中，我们发送的是字符串，因为字符串是可序列化的。如果需要发送其他类型的数据，可以考虑使用Python的pickle模块进行序列化。