导语:
本文主要介绍了关于python Pool常用函数有哪些的相关知识,包括python常用函数大全,以及python函数调用这些编程知识,希望对大家有参考作用。
说明
1. apply_async(func[, args[, kwds]):使用非阻塞调用func(并行执行,阻塞方式必须等待上一个进程退出后才能执行下一个进程),args是传给func的参数列表, kwds 是传递给 func 的关键字参数列表。
2、close():关闭Pool,使之不再接受新任务。
3、terminate():无论任务是否完成,都要立即终止。
4.join():主进程被阻塞,等待子进程退出,必须在close或terminate之后使用。
实例
#coding: utf-8
import multiprocessing
import time
def func(msg):
print("msg:", msg)
time.sleep(3)
print("end")
if __name__ == "__main__":
cores = multiprocessing.cpu_count()
pool = multiprocessing.Pool(processes=cores)
print("Adding tasks...")
for i in range(cores):
msg = "hello %d" %(i)
pool.apply_async(func, (msg, )) #维持执行的进程总数为processes,当一个进程执行完毕后会添加新的进程进去
print("Starting tasks...")
pool.close()
pool.join() #调用join之前,先调用close函数,否则会出错。执行完close后不会有新的进程加入到pool,join函数等待所有子进程结束
print("Sub-process(es) done.")
本文教程操作环境:windows7系统、Python 3.9.1,DELL G3电脑。
本文为原创文章,版权归知行编程网所有,欢迎分享本文,转载请保留出处!
你可能也喜欢
- ♥ Python:函数参数类型和排序总结01/10
- ♥ 如何在python字典中获取关联值?12/23
- ♥ 为什么在python3.4中打印不换行?01/06
- ♥ python中的线程和协程有什么区别11/19
- ♥ 如何在python中使用popitem09/21
- ♥ python切片符号介绍01/05
内容反馈