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