python - 如何等待所有进程结束

Question

我已经并行运行了两个Process实例:

from multiprocessing import Process

def foobar():
  return x*x

def barfoo():
  return x+x

thread_fb = Process(target = foobar, args=(3,)))
thread_bf = Process(target = barfoo, args=(3,)))
thread_fb.start(); thread_bf.start()
thread_fb.wait(); thread_bf.wait()

它引发了此错误:

AttributeError: 'Process' object has no attribute 'wait'

如何等待所有multiprocessing.Process结束？

使用threading其他多处理/线程库时的等效项是什么？

Answer 1

使用 Process.join ，本质上是为“wait”使用行话:

thread_fb.start()
thread_bf.start()
thread_fb.join()
thread_bf.join()