felixpk · November 8, 2019 16:39
diff --git a/tqdm_with_process_pool_executor.py b/tqdm_with_process_pool_executor.py
 import multiprocessing as mp
 from concurrent import futures
 from concurrent.futures import ProcessPoolExecutor

 def foo(doc):
    pass

 with ProcessPoolExecutor(max_workers=4, mp_context=mp.get_context('spawn')) as executor:
    tasks = [executor.submit(foo, doc) for doc in all_docs]

    with tqdm(total=docs_count) as pbar:
        for _ in futures.as_completed(tasks):
            pbar.update()
	import multiprocessing as mp
	from concurrent import futures
	from concurrent.futures import ProcessPoolExecutor

	def foo(doc):
	pass

	with ProcessPoolExecutor(max_workers=4, mp_context=mp.get_context('spawn')) as executor:
	tasks = [executor.submit(foo, doc) for doc in all_docs]

	with tqdm(total=docs_count) as pbar:
	for _ in futures.as_completed(tasks):
	pbar.update()
No results found