进度条监控
tqdm
结合 multiprocessing
和 tqdm
:
import multiprocessing
from tqdm import tqdm
def worker(args):
# 具体任务逻辑
return result
if __name__ == "__main__":
with multiprocessing.Pool() as pool:
results = list(tqdm(
pool.imap_unordered(worker, task_list),
total=len(task_list),
desc="Processing"
))