首页 / 知识

python 管道

2023-11-12 13:31:00

创建管道的类：

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