说明
1、apply_async(func[,args[,kwds]):使用非堵塞调用func(并行执行,必须等待上一个过程退出才能执行下一个过程)。args是传输给func的参数列表,kwds是传输给func的关键字参数列表。
2、close():关闭Pool,使其不再接受新任务。
3、terminate():无论任务是否完成,都应立即终止。
4、join():主过程堵塞,等待子过程退出,必须在close或terminate之后使用。
实例
#coding:utf-8 importmultiprocessing importtime deffunc(msg): print("msg:",msg) time.sleep(3) print("end") if__name__=="__main__": cores=multiprocessing.cpu_count() pool=multiprocessing.Pool(processes=cores) print("Addingtasks...") foriinrange(cores): msg="hello%d"%(i) pool.apply_async(func,(msg,))#保持执行的过程总数为processes,当一个过程完成后,将添加新的过程 print("Startingtasks...") pool.close() pool.join()#在调用join之前,先调用close函数,否则会出错。close执行后,pool中不会添加新的进程,join函数等待所有子进程结束 print("Sub-process(es)done.")
以上是python Pool常用函数的介绍,希望对大家有所帮助。学习更多编程基础知识:python学习网
本文教程操作环境:windows7系统Python 3.9.1,DELL G3电脑。