tqdm_mt.py

import random
import time
from concurrent import futures
from concurrent.futures import ThreadPoolExecutor
from tqdm import tqdm


def run(task_num):
    with tqdm(range(100), desc='Task %d' % task_num, position=task_num) as progress:
        for _ in progress:
            time.sleep(float(random.randint(10, 100)) / 100)


if __name__ == '__main__':
    with ThreadPoolExecutor(max_workers=4) as executor:
        tasks = [executor.submit(run, task_num) for task_num in range(10)]
        for task in futures.as_completed(tasks):
            task.result()