知行编程网知行编程网  2022-11-27 12:30 知行编程网 隐藏边栏  7 
文章评分 0 次,平均分 0.0
导语: 本文主要介绍了关于python Pool常用函数有哪些的相关知识,包括python常用函数大全,以及python函数调用这些编程知识,希望对大家有参考作用。

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

本文为原创文章,版权归所有,欢迎分享本文,转载请保留出处!

知行编程网
知行编程网 关注:1    粉丝:1
这个人很懒,什么都没写
扫一扫二维码分享