fromconcurrent.futuresimportThreadPoolExecutordata= [list(range(0,5)),list(range(5,10)),]def_f(x):print(f"Processing{x}")returnTrueprint("=== 1 - No consumption from the iterator ===")executor=ThreadPoolExecutor(max_workers=1)forintsindata:executor.map(_f,ints)executor.shutdown(wait=True)print("=== 2 - Consume all values from the iterator ===")executor=ThreadPoolExecutor(max_workers=1)forintsindata:futures=executor.map(_f,ints)results=list(futures)executor.shutdown(wait=True)print("=== 3 - Consume one value from the iterator ===")executor=ThreadPoolExecutor(max_workers=1)forintsindata:futures=executor.map(_f,ints)first=next(futures)executor.shutdown(wait=True)print("=== 4 - Dropping iterator cancels remaining futures ===")executor=ThreadPoolExecutor(max_workers=1)futures=executor.map(_f,range(0,5))first=next(futures)delfuturesexecutor.shutdown(wait=True)

=== 1 - No consumption from the iterator ===Processing 0Processing 1Processing 2Processing 3Processing 4Processing 5Processing 6Processing 7Processing 8Processing 9=== 2 - Consume all values from the iterator ===Processing 0Processing 1Processing 2Processing 3Processing 4Processing 5Processing 6Processing 7Processing 8Processing 9=== 3 - Consume one value from the iterator ===Processing 0Processing 1Processing 5Processing 6Processing 7Processing 8Processing 9=== 4 - Dropping iterator cancels remaining futures ===Processing 0Processing 1