Python concurrent.futures example

gistfile1

from concurrent.futures import ProcessPoolExecutor, wait
from multiprocessing import cpu_count

try:
    workers = cpu_count()
except NotImplementedError:
    workers = 1

pool = ProcessPoolExecutor(max_workers=workers)

def hard_work():
    # Do some CPU bond work here
    pass

futures = [pool.submit(hard_work) for x in range(100)]
wait(futures)