zoukankan      html  css  js  c++  java
  • 使用pool的多进程,不执行的问题

        from multiprocessing import Pool

        def fetch_data(idlist,test):

            pass

        p=Pool(4)

        result=[]

        for i in range(0,len(idlist)-2,2):

            result.append(p.apply_async(fetch_data,args=(idlist[i:i+2,test2)))

        # result.append(apply_async(fetch_data,args=(idlist[i+2:],test2)))

        print('Child process will start.')

        p.close()#关闭进程池,不让新的进程加入

        p.join()#阻塞进程直到子进程完成

        columns=[]

       #获取子进程的return返回结果

        for i in result:

            columns+=i.get()

    大体结构如上,有时会出现程序完整运行,没有报错,但子进程也没有的执行的情况,很困惑。

    现在想来可能是子进程出现了错误,但是这个错误不会被抛到主进程,因而看不到,下次,子进程未运行时,可以单独测试

    一下子进程的程序,调整好,再放入主程序。

  • 相关阅读:
    POJ3613 k边最短路
    洛谷4014最大/小费用最大流
    POJ1734无向图求最小环
    洛谷4013数字梯形
    洛谷4147玉蟾宫
    洛谷4145上帝造题的七分钟2
    洛谷4092 树
    Nginx动静分离-tomcat
    nginx之Geoip读取地域信息模块
    Nginx与Lua开发
  • 原文地址:https://www.cnblogs.com/Ting-light/p/9547279.html
Copyright © 2011-2022 走看看