本文介绍了多处理时调用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()
正在阻止操作。
第一个示例:
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秒!。
这篇关于多处理时调用Join()的位置的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!