from multiprocessing import Pool
with Pool(processes=6) as p:
p.starmap(update_tabl, zip(r))
我正在使用此处概述的方法:https://web.archive.org/web/20170625154652/http://n-s-f.github.io/2016/12/23/starmap-pattern.html https://web.archive.org/web/20170625154652/http://n-s-f.github.io/2016/12/23/starmap-pattern.html并行调用函数update_table
返回数据帧作为输出。
我如何连接所有这些数据帧?我可以用pd.concat
如果我使用 for 循环但不知道如何并行执行
您可以对星图的结果进行连接:
with Pool(processes=6) as p:
res = pd.concat(p.starmap(update_table, zip(rows)))
# do stuff with res
连接不会并行发生,而是在星图完成后发生。
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)