tqdm_concurrent_futures.py

import concurrent.futures
from tqdm import tqdm

def run_multiprocess(func, iterator):
    with concurrent.futures.ProcessPoolExecutor() as executor:
        results = list(tqdm(executor.map(func, iterator), total=len(iterator)))
    return results