example of using concurrent.futures map and as completed to submit a bunch of "jobs" and deal with the results as they complete.

gistfile1.py

from concurrent.futures import as_completed, ThreadPoolExecutor
import random
import time
 
def do_some_work(work_input):
    result = random.choice(range(1,2))
    print("sleeping for %s (%s)" % (result, work_input))
    time.sleep(result)
    return (result, work_input)
    
 
with ThreadPoolExecutor(8) as ex:
    for f in as_completed([ex.submit(do_some_work, x) for x in range(1, 100)]):
        print(f.result())