python 管道
推荐
在线提问>>
创建管道的类：
Pipe([duplex]):在进程之间创建一条管道，并返回元组(conn1,conn2),其中conn1，conn2表示管道两端的连接对象，强调一点：必须在产生Process对象之前产生管道
参数介绍：
dumplex:默认管道是全双工的，如果将duplex射成False，conn1只能用于接收，conn2只能用于发送。
frommultiprocessingimportProcess,Pipe
importtime,os
defconsumer(p,name):
left,right=p
left.close()
whileTrue:
try:
baozi=right.recv()
print('%s收到包子:%s'%(name,baozi))
exceptEOFError:
right.close()
break
defproducer(seq,p):
left,right=p
right.close()
foriinseq:
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=(iforiinrange(10))
producer(seq,(left,right))
right.close()
left.close()
c1.join()
print('主进程')
注意：生产者和消费者都没有使用管道的某个端点，就应该将其关闭，如在生产者中关闭管道的右端，在消费者中关闭管道的左端。如果忘记执行这些步骤，程序可能再消费者中的recv()操作上挂起。管道是由操作系统进行引用计数的,必须在所有进程中关闭管道后才能生产EOFError异常。因此在生产者中关闭管道不会有任何效果，付费消费者中也关闭了相同的管道端点。
管道可以用于双向通信，利用通常在客户端/服务器中使用的请求/响应模型或远程过程调用，就可以使用管道编写与进程交互的程序
frommultiprocessingimportProcess,Pipe
importtime,os
defadder(p,name):
server,client=p
client.close()
whileTrue:
try:
x,y=server.recv()
exceptEOFError:
server.close()
break
res=x+y
server.send(res)
print('serverdone')
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相关知识，请关注IT培训机构:千锋教育。
