test_pool.py

from multiprocessing import Pool, cpu_count
from time import sleep

def f(x):
    for i in range(10):
        print 'counting %d --- Process:%d ' % (i, x)
        sleep(1.0+float(x % cpu_count())/5)


def main():
    pool = Pool(processes=cpu_count()) 
    for i in range(10):
        result = pool.apply_async(f, (i,))
    pool.close()
    pool.join()
    if result.successful():
        print 'successful'


if __name__ == "__main__":
    main()