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

2020-03-14 15:02:04 阅读：265 来源： 互联网

标签：__ 数据通信 Process 第三十九 Pipe 管道进程 conn2 conn1

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

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。

ICode9

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

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