python 管道

　　创建管道的类：

　　Pipe([duplex]):在进程之间创建一条管道，并返回元组(conn1,conn2),其中conn1，conn2表示管道两端的连接对象，强调一点：必须在产生Process对象之前产生管道

　　参数介绍：

　　dumplex:默认管道是全双工的，如果将duplex射成False，conn1只能用于接收，conn2只能用于发送。

　　from multiprocessing import Process,Pipe

　　import time,os

　　def consumer(p,name):

　　left,right=p

　　left.close()

　　while True:

　　try:

　　baozi=right.recv()

　　print('%s 收到包子:%s' %(name,baozi))

　　except EOFError:

　　right.close()

　　break

　　def producer(seq,p):

　　left,right=p

　　right.close()

　　for i in seq:

　　left.send(i)

　　# time.sleep(1)

　　else:

　　left.close()

　　if __name__ == '__main__':

　　left,right=Pipe()

　　c1=Process(target=consumer,args=((left,right),'c1'))

　　c1.start()

　　seq=(i for i in range(10))

　　producer(seq,(left,right))

　　right.close()

　　left.close()

　　c1.join()

　　print('主进程')

　　注意：生产者和消费者都没有使用管道的某个端点，就应该将其关闭，如在生产者中关闭管道的右端，在消费者中关闭管道的左端。如果忘记执行这些步骤，程序可能再消费者中的recv()操作上挂起。管道是由操作系统进行引用计数的,必须在所有进程中关闭管道后才能生产EOFError异常。因此在生产者中关闭管道不会有任何效果，付费消费者中也关闭了相同的管道端点。

　　管道可以用于双向通信，利用通常在客户端/服务器中使用的请求/响应模型或远程过程调用，就可以使用管道编写与进程交互的程序

　　from multiprocessing import Process,Pipe

　　import time,os

　　def adder(p,name):

　　server,client=p

　　client.close()

　　while True:

　　try:

　　x,y=server.recv()

　　except EOFError:

　　server.close()

　　break

　　res=x+y

　　server.send(res)

　　print('server done')

　　if __name__ == '__main__':

　　server,client=Pipe()

　　c1=Process(target=adder,args=((server,client),'c1'))

　　c1.start()

　　server.close()

　　client.send((10,20))

　　print(client.recv())

　　client.close()

　　c1.join()

　　print('主进程')

　　#注意：send()和recv()方法使用pickle模块对对象进行序列化。

　　以上内容为大家介绍了python 管道，希望对大家有所帮助，如果想要了解更多Python相关知识，请关注多测师。https://www.e70w.com/xwzx/