Python并发编程-管道

Posted 2021-01-08 空林~~清风~~~

管道的作用- 两个进程间传递消息

from multiprocessing import Pipe, Process

def func(conn1,conn2):
    conn2.close() #子进程只需使用connection1,故关闭connection2
    while True:
        try:
            msg = conn1.recv()
            print(msg)
        except EOFError:  #没收数据接收的时候,才抛出的异常
            conn1.close()
            break

if __name__ == '__main__':
    conn1,conn2 = Pipe()#建立一个管道,管道返回两个connection
    Process(target=func, args=(conn1,conn2)).start()
    conn1.close() #主进程只需要一个connection,故关闭一个
    for i in range(20):
        conn2.send('吃了吗') #主进程发送
    conn2.close() #主进程关闭connection2