1.管道：Pipe，管道是双向通信的，左边传入的数据，输送到管道内的右边，输出时从右边输出，从左边接受到的数据传输到右边从从左边输出
1.1主进程和子进程之间的通讯：
from multiprocessing import Pipe,Process def func(conn1): pass conn1.send(‘helloword‘) if __name__==‘__main__‘: conn1,conn2= Pipe() #创建一个管道 p=Process(target=func,args=(conn1,)) p.start() print(conn2.recv())#当管道内没有数据的时候程序会进入堵塞状态 结果为 C:\pycharm\python.exe D:/python练习程序/第三十九天/pipe.py helloword
1.2子进程与子进程之间的通讯：
from multiprocessing import Pipe,Process def func(conn1): conn1.send(‘helloword‘) def func2(conn2): msg=conn2.recv() print(msg) if __name__==‘__main__‘: conn1,conn2= Pipe() #创建一个管道 p=Process(target=func,args=(conn1,)) p.start() p1=Process(target=func2,args=(conn2,)) p1.start() 结果为 helloword
1.3看下面程序有什么现象，并且如何进行改进：
from multiprocessing import Pipe,Process def func(conn1): while True: msg=conn1.recv() print(msg) if __name__==‘__main__‘: conn1,conn2= Pipe() #创建一个管道 p=Process(target=func,args=(conn1,)) p.start() for i in range(20): conn2.send(‘是否结束‘)
结果为
通过结果我们可以发现程序一直在堵塞阶段无法进行结束
1.4改进措施：
from multiprocessing import Pipe,Process def func(conn1): while True: msg=conn1.recv() if msg is None:break print(msg) if __name__==‘__main__‘: conn1,conn2= Pipe() #创建一个管道 p=Process(target=func,args=(conn1,)) p.start() for i in range(20): conn2.send(‘是否结束‘) conn2.send(None) #当数据传输完成之后在发送一个数据判断位
改进措施二：
from multiprocessing import Pipe,Process def func(conn1,conn2): while True: conn2.close() try: msg=conn1.recv() print(msg) except EOFError: conn1.close() break if __name__==‘__main__‘: conn1,conn2= Pipe() #创建一个管道 p=Process(target=func,args=(conn1,conn2)) p.start() conn1.close() for i in range(20): conn2.send(‘是否结束‘) conn2.close()
1.5总结：
管道端点的正确管理问题，如果生产者或者消费者中没有使用管道中的某个端点，就应该将其关闭，这也就是说为什么在生产过程中关闭了输出端管道，在消费
者中关闭了输入管道。如果忘记执行这些步骤，程序可能在消费者的recv中启动进程。管道是由操作系统进行计数的，必须在所有进程中关闭管道后才会生成Eoferror异常。因此，在生产者中关闭管道不会有任何效果，除非消费者也关闭了相同的管道端点。
1.6用管道做生产包子的程序：
原文：https://www.cnblogs.com/ab461087603/p/12492206.html
