• 技术文章 >Python技术 >Python基础教程

    python Pool常用函数有哪些

    小妮浅浅小妮浅浅2021-07-23 09:50:06原创3414

    说明

    1、apply_async(func[,args[,kwds]):使用非堵塞调用func(并行执行,堵塞方式必须等待上一个过程退出才能执行下一个过程),args是传输给func的参数列表,kwds是传输给func的关键词参数列表。

    2、close():关闭Pool,使之不再接受新任务。

    3、terminate():无论任务是否完成,都要立即终止。

    4、join():主进程堵塞,等待子进程退出,必须在close或terminate之后使用。

    实例

    1

    2

    3

    4

    5

    6

    7

    8

    9

    10

    11

    12

    13

    14

    15

    16

    17

    18

    19

    20

    21

    22

    #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.")

    以上就是python Pool常用函数的介绍,希望对大家有所帮助。更多编程基础知识学习:python学习网

    本文教程操作环境:windows7系统、Python 3.9.1,DELL G3电脑。

    专题推荐:python pool
    上一篇:python中进程池Pool的初始化 下一篇:python中figure()函数画两张图

    相关文章推荐

    • 如何使用python中threadpool模块?• ThreadPoolExecutor在java中创建线程池• python如何下载模块• python函数的理解及定义• python调用函数的注意点• python中函数的作用探究• python try-except捕获异常的方法• python中try-except-finally语句的使用• python raise语句的两种用法• python类如何实例化对象• python对象方法是什么• python模块的介绍和导入• python模块如何传入参数• python密码生成器的使用• python如何使用send唤醒• python WSGI规范是什么• python整数的进制转换• python中Queue如何通信• python中进程池Pool的初始化

    全部评论我要评论

    © 2021 Python学习网 苏ICP备2021003149号-1

  • 取消发布评论
  • 

    Python学习网