#_*_coding:utf-8_*_

 from multiprocessing import  Pool

 import time

 def f(x):

     #制造一个进程超时的效果

     if x == 4:

         time.sleep(4)

     else:

         time.sleep(1)

     return x*x

 if __name__ == '__main__':

    pool = Pool(processes=4)

    res_list = []

    #执行方法，res= pool.apply_async(f,[i,])  这只是一种写法.以下这些行用这一条就能搞定print pool.map(f,range(5))

    for i in range(5):

     #异步方式

     res= pool.apply_async(f,[i,])

     print '----:',i

     res_list.append(res)

    #循环获取结果

    for i in res_list:

         try:

            #打印结果，如果获取结果超过2秒钟将报异常

            print i.get(timeout=2)

         except Exception:

             print "进程:%s 获取结果超时"% i