python 进程池的使用

#!/usr/bin/env python#coding:utf-8frommultiprocessing import Pooldef Func(param1, param2, param3, ...):...if __name__ == '__main__':pool = Pool(5) #定义一个个进程的进程池for ... :pool.app

chuangchuangtao

239人浏览 · 2017-08-18 19:03:35

chuangchuangtao · 2017-08-18 19:03:35 发布

#!/usr/bin/env python
#coding:utf-8

from  multiprocessing import Pool

def Func(param1, param2, param3, ...):
    ...

if __name__ == '__main__':

    pool = Pool(5) #定义一个个进程的进程池

    for ... :
        pool.apply_async(func=Func, args=(param1, param2, param3, ...))


    pool.close() #关闭进程池
    pool.join() #进程池中进程执行完毕后关闭(先close再join)