zoukankan      html  css  js  c++  java
  • Python入门学习笔记16(进程池)

    进程池

    进程池与线程的信号量相似,用来控制同一时间活动的最大进程个数。

    import time
    from multiprocessing import Pool
    
    def func(i):
        time.sleep(1)
        print("process[%d]" %i)
        return "[%d] callback" %i
    
    def callback(*args):
        print("callback:",args)
    
    if __name__ == "__main__":
        pool = Pool(2)
        """
        10个进程创建之后有2个进入进程池,其他的进程处于未启动状态
        """
        for i in range(10):
            """
            apply,串行处理,不管持之有多大一次只有一个进程在运行
            apply_async,并行处理
            """
            """
            callback,回调函数,接收进程返回作为参数
            """
            # pool.apply(func=func,args=(i,))
            pool.apply_async(func=func,args=(i,),callback=callback)
    
        """
        进程池的join必须在close之后,如果close之后不进行join,那么所有的进程会一并随着主进程结束而结束
        """
        pool.close()
        pool.join()
    

      

  • 相关阅读:
    Servlet细节
    https协议
    常用css缩写
    Servlet
    计算机编码总结
    java 中 finally 语句块的 深度解析 总结
    使用DIV之后 table何去何从
    http协议
    web开发基础
    js闭包之我见
  • 原文地址:https://www.cnblogs.com/Hexdecimal/p/9418543.html
Copyright © 2011-2022 走看看