第三十九天 数据通信和进程池

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

View Code

　　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

View Code

    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('是否结束')

View Code

结果为

 

 通过结果我们可以发现程序一直在堵塞阶段无法进行结束

　　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) #当数据传输完成之后在发送一个数据判断位

View Code

　　改进措施二：

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()

View Code

　　1.5总结：

管道端点的正确管理问题，如果生产者或者消费者中没有使用管道中的某个端点，就应该将其关闭，这也就是说为什么在生产过程中关闭了输出端管道，在消费

者中关闭了输入管道。如果忘记执行这些步骤，程序可能在消费者的recv中启动进程。管道是由操作系统进行计数的，必须在所有进程中关闭管道后才会生成Eoferror异常。因此，在生产者中关闭管道不会有任何效果，除非消费者也关闭了相同的管道端点。

　　1.6用管道做生产包子的程序：

 

标签：__,数据通信,Process,第三十九,Pipe,管道,进程,conn2,conn1
来源： https://www.cnblogs.com/ab461087603/p/12492206.html