python并发——从线程池获取返回值

并发是快速处理大量相似任务的绝佳办法,但对于有返回值的方法,需要一个容器专门来存储每个进程处理完的结果

from multiprocessing import Pool

import time

#返回值只有进程池才有,父子进程没有返回值

def func(i):

    time.sleep(1)

    return i*i

if __name__ == '__main__':

    p = Pool(5)

    #从异步提交任务获取结果

    res_l = []

    for i in range(20):

        res = p.apply_async(func,args=(i,))

        res_l.append(res)

    for res in res_l:

        print(res.get()) 

还有使用map的方式:

from multiprocessing import Pool

import time

def func(i): #返回值只有进程池才有,父子进程没有返回值

    time.sleep(0.5)

    return i*i

if __name__ == '__main__':

    p = Pool(5)

    ret = p.map(func,range(10))

    print(ret)