创建管道的类：

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培训机构:千锋教育。

上一篇

Python 运算符

下一篇

python怎么创建模块?