zoukankan      html  css  js  c++  java
  • 09 进程池的异步方法

    import time
    from multiprocessing import Process,Pool
    
    
    def f1(n):
        time.sleep(0.5)
        # print(n)
        return n*n
    
    if __name__ == '__main__':
    
        pool = Pool(4)
    
        res_list = []
        for i in range(10):
            print('xxxx')
            #异步给进程池提交任务
            res = pool.apply_async(f1,args=(i,))
            res_list.append(res)
    
        # print('等待所有任务执行完')
        # pool.close()  #锁住进程池,意思就是不让其他的程序再往这个进程池里面提交任务了
        # pool.join()
    
        #打印结果,如果异步提交之后的结果对象
        for i in res_list:
            print(i.get())
    
    
    
    
        # time.sleep(10)
    

      

  • 相关阅读:
    洛朗级数
    泰勒级数
    中心极限定理
    置信区间公式
    简单随机样本的性质
    极大似然估计
    矩估计法
    摆摊70
    天天去哪吃
    天天和树
  • 原文地址:https://www.cnblogs.com/work14/p/10267109.html
Copyright © 2011-2022 走看看