python Pool常用函数有哪些

说明

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电脑。