1 #_*_coding:utf-8_*_ 2 from multiprocessing import  Pool 3 import time 4  5 def f(x): 6     #制造一个进程超时的效果 7     if x == 4: 8         time.sleep(4) 9     else:10         time.sleep(1)11     return x*x12 13 14 15 if __name__ == ‘__main__‘:16    pool = Pool(processes=4)17    res_list = []18    #执行方法，res= pool.apply_async(f,[i,])  这只是一种写法.以下这些行用这一条就能搞定print pool.map(f,range(5))19    for i in range(5):20     #异步方式21     res= pool.apply_async(f,[i,])22     print ‘----:‘,i23     res_list.append(res)24    #循环获取结果25    for i in res_list:26         try:27            #打印结果，如果获取结果超过2秒钟将报异常28            print i.get(timeout=2)29         except Exception:30             print "进程:%s 获取结果超时"% i