使用tqdm与current.futures？

使用tqdm与current.futures？

你可以用

tqdm

周围

executor

，如下跟踪进度：

list(tqdm(executor.map(f, iter), total=len(iter))

这是您的示例：

import time  import concurrent.futuresfrom tqdm import tqdmdef f(x):    time.sleep(0.001)  # to visualize the progress    return x**2def run(f, my_iter):    with concurrent.futures.ThreadPoolExecutor() as executor:        results = list(tqdm(executor.map(f, my_iter), total=len(my_iter)))    return resultsmy_iter = range(100000)run(f, my_iter)

结果是这样的：

16%|██▏| 15707/100000 [00:00<00:02, 31312.54it/s]