本文介绍了在这个文件中,我用pool.map做错了什么,导致什么都没有出现,并且我必须重新启动外壳程序?的处理方法,对大家解决问题具有一定的参考价值,需要的朋友们下面随着小编来一起学习吧!
问题描述
在下面的使用多处理的python文件中,我遗漏了什么或者做错了什么?当我运行它时,没有任何反应,我必须重新启动外壳程序!def f(x):
lo=0
for i in range(x):
lo+=i
return(lo)
from multiprocessing import Pool
def f_parallel(x1,x2,x3,x4):
with Pool(processes=4) as pool:
resulto_parallel=pool.map(f,[x1,x2,x3,x4])
return(resulto_parallel)
f_parallel(1,2,3,4)
下面是我运行它时发生的情况的屏幕快照。
等待一段时间后,我只需重新启动外壳。
推荐答案
引用自the multiprocessing docs:
应使用
保护程序的"入口点"if __name__ == '__main__'
在您的情况下,如下所示:
from multiprocessing import Pool
def f(x):
lo = 0
for i in range(x):
lo += i
return lo
def f_parallel(x1, x2, x3, x4):
with Pool(processes=4) as pool:
resulto_parallel = pool.map(f, [x1, x2, x3, x4])
return resulto_parallel
if __name__ == '__main__':
print(f_parallel(1, 2, 3, 4))
关键是派生的进程将导入您的python脚本,如果不保护对f_parallel(1,2,3,4)
的调用,将导致子进程无休止的派生。
注意:还添加了print
,以便将函数调用的结果实际放入stdout
这篇关于在这个文件中,我用pool.map做错了什么,导致什么都没有出现,并且我必须重新启动外壳程序?的文章就介绍到这了,希望我们推荐的答案对大家有所帮助,也希望大家多多支持编程学习网!
本站部分内容来源互联网,如果有图片或者内容侵犯您的权益请联系我们删除!