ITPub博客

首页 > 应用开发 > Python > Python多进程之数据交换Pipe

Python多进程之数据交换Pipe

原创 Python 作者:ckxllf 时间:2021-03-02 20:29:22 0 删除 编辑

  multiprocessing.Pipe()方法会返回一个管道(列表的形式)的两个端口,一个端口作为输入端,一个端口作为输出端,如进程A的输出可以作为进程B的输入,进程B的输出可以作为进程A的输入,默认是全双工模式。

  Pipe()方法返回的对象具有发送消息send()方法和接收消息recv()方法。调用接收recv()方法时,如果管道中没用消息会一直阻塞,如果管道关闭,则会抛出EOFError异常。

  示例:

  import multiprocessing

  import time

  def task1(pipe):

  for i in range(5):

  str = f"task1-{i}"

  print(f"{time.strftime('%H:%M:%S')} task1 发送:{str}")

  pipe.send(str)

  time.sleep(2)

  for i in range(5):

  print(f"{time.strftime('%H:%M:%S')} task1 接收: { pipe.recv() }")

  def task2(pipe):

  for i in range(5):

  print(f"{time.strftime('%H:%M:%S')} task2 接收: { pipe.recv() }")

  time.sleep(1)

  for i in range(5):

  str = f"task2-{i}"

  print(f"{time.strftime('%H:%M:%S')} task2 发送:{str}")

  pipe.send(str)

  if __name__ == "__main__":

  pipe = multiprocessing.Pipe()

  p1 = multiprocessing.Process(target=task1, args=(pipe[0],)) # pipe[0]管道发送消息的端口

  p2 = multiprocessing.Process(target=task2, args=(pipe[1],)) # pipe[1]管道接收消息的端口

  p1.start()

  p2.start()

  p1.join()

  p2.join()

  输出: 大连人流医院

  17:23:53 task1 发送:task1-0

  17:23:53 task1 发送:task1-1

  17:23:53 task1 发送:task1-2

  17:23:53 task1 发送:task1-3

  17:23:53 task1 发送:task1-4

  17:23:53 task2 接收: task1-0

  17:23:53 task2 接收: task1-1

  17:23:53 task2 接收: task1-2

  17:23:53 task2 接收: task1-3

  17:23:53 task2 接收: task1-4

  17:23:54 task2 发送:task2-0

  17:23:54 task2 发送:task2-1

  17:23:54 task2 发送:task2-2

  17:23:54 task2 发送:task2-3

  17:23:54 task2 发送:task2-4

  17:23:55 task1 接收: task2-0

  17:23:55 task1 接收: task2-1

  17:23:55 task1 接收: task2-2

  17:23:55 task1 接收: task2-3

  17:23:55 task1 接收: task2-4

  说明:定义了两个任务函数,task1先发5条消息,再接收消息,task2先接收消息,再发送消息。调用time.sleep()只是让输出更好看点,不会影响管道的接收和发送。

来自 “ ITPUB博客 ” ,链接:http://blog.itpub.net/69945560/viewspace-2760726/,如需转载,请注明出处,否则将追究法律责任。

请登录后发表评论 登录
全部评论

注册时间:2019-08-16

  • 博文量
    198
  • 访问量
    174401