多处理时在哪里调用 join()

在 Python 中使用多处理时，我通常会看到以下示例：join()函数在每个进程实际创建的单独循环中调用。

例如，这个：

processes = []

for i in range(10):
    p = Process(target=my_func)
    processes.append(p)
    p.start()

for p in processes:
    p.join()

比这个更常见的是：

processes = []

for i in range(10):
    p = Process(target=my_func)
    processes.append(p)
    p.start()
    p.join()

但从我的理解来看join()，它只是告诉脚本在该过程完成之前不要退出。因此，什么时候应该不重要join()叫做。那么为什么通常在单独的循环中调用它呢？

join()正在阻塞操作。

在第一个示例中，您启动 10 个进程，然后等待所有进程完成。所有进程同时运行。

在第二个示例中，您一次启动一个进程，并在启动另一个进程之前等待完成。同一时刻只有一个进程在运行

第一个例子：

def wait()
    time.sleep(1)

# You start 10 processes
for i in range(10):
    p = Process(target=wait)
    processes.append(p)
    p.start()

# One second after all processes can be finished you check them all and finish
for p in processes:
    p.join()

整个脚本的执行时间可能很接近一秒.

第二个例子：

for i in range(10):
    p = Process(target=wait) # Here you start one process 
    processes.append(p)
    p.start()
    p.join() # Here you will have to wait one second before process finished.

整个脚本的执行时间可能很接近10秒！.