threadpool_sample

from multiprocessing.pool import ThreadPool
from os import getpid
from time import sleep


def fn_sleep(s):
    sleep(s)
    return getpid()


sleep_time = [10, 10, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1, 1]
pool = ThreadPool()
async_results = []
for s_ in sleep_time:
    async_result = pool.apply_async(fn_sleep, kwds={'s': s_})
    async_results.append(async_result)
print [async_result.get() for async_result in async_results]