python 管道

发布时间:2022-05-09 09:41:19 人气:20 作者:多测师

  创建管道的类:

  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()

python 管道

  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/


上一篇:python 进程间通信
下一篇:python 进程池
返回列表
在线客服
联系方式

热线电话

17727591462

上班时间

周一到周五

二维码
线