相关疑难解决方法(0)

在Python中使用dask将tqdm与延迟执行结合起来

tqdm并且dask是在Python迭代都惊人的包。在tqdm实现所需的进度条的同时,dask实现了多线程平台,它们都可以使迭代过程更轻松。但是-我很难将它们结合在一起。

例如,以下代码dask使用tqdm.trange进度条在中实现了延迟执行。事实是,由于delayed迅速执行,进度条立即结束,而真正的计算时间工作则在compute零件中完成。

from dask import delayed,compute
from tqdm import trange
from time import sleep

ct = time()
result= []

def fun(x):
    sleep(x)
    return x

for i in trange(10):
    result.append(delayed(fun)(i))

print compute(result)
Run Code Online (Sandbox Code Playgroud)

如何将进度条附加到compute命令的实际执行中?

python dask tqdm

5
推荐指数
2
解决办法
757
查看次数

标签 统计

dask ×1

python ×1

tqdm ×1