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()
    

      

  • 相关阅读:
    安装PyExecJS出现问题
    常用模块
    python2和python3的区别
    正则表达式
    MySQL之表的关系
    Python与MySQL的交互
    select 查询
    MySQL之表的连接
    bug
    黑盒测试-判定表驱动法
  • 原文地址:https://www.cnblogs.com/Hexdecimal/p/9418543.html
Copyright © 2011-2022 走看看