charm.pool.map & tqdm:获取进度条
charm.pool.map & tqdm:获取进度条
提问于 2020-08-31 20:39:05
我正在使用漫游满库charm4py在由几台机器组成的集群上并行执行任务。我只是使用there文档中的charm.pool.map函数。
使用经典的list(tqdm.tqdm(char.pool.map(...),total=...))不起作用:只有在最后一次迭代之后才会打印进度条。
我该怎么写呢？这有可能吗？
编辑:在charm4py问题上交叉发布：https://github.com/UIUC-PPL/charm4py/issues/178
回答 1
Stack Overflow用户
回答已采纳
发布于 2020-09-06 19:47:00
遵循@lrnv关于multi_future的建议，下面的代码应该正确地显示工作进程池的进度。
from charm4py import charm
from tqdm import tqdm
futures = charm.pool.map_async(func, iterable, multi_future=True)
pBar = tqdm(total=len(futures))
for future in charm.iwait(futures):
# Do something with future.get()
pBar.update()页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/63671000
复制相关文章
相似问题
腾讯云开发者
