[求助提问] subprocess 的并行的一个问题 - V2EX
V2EX = way to explore
V2EX 是一个关于分享和探索的地方
现在注册
已注册用户请  登录
推荐学习书目
Learn Python the Hard Way
Python Sites
PyPI - Python Package Index
http://diveintopython.org/toc/index.html
Pocoo
值得关注的项目
PyPy
Celery
Jinja2
Read the Docs
gevent
pyenv
virtualenv
Stackless Python
Beautiful Soup
结巴中文分词
Green Unicorn
Sentry
Shovel
Pyflakes
pytest
Python 编程
pep8 Checker
Styles
PEP 8
Google Python Style Guide
Code Style from The Hitchhiker's Guide
eccentric579
V2EX    Python

[求助提问] subprocess 的并行的一个问题

  •  
  •   eccentric579 2022-04-12 23:17:46 +08:00 2651 次点击
    这是一个创建于 1279 天前的主题,其中的信息可能已经有所发展或是发生改变。
    class test(object): def __init__(self) -> None: self.p = None self.data = None def request(self): self.p = subprocess.Popen(['pwsh' ,'-Command' ,'ping', '127.0.0.1'], stdout=subprocess.PIPE, encoding='gbk') def process(self): self.data = self.p.communicate()[0] if __name__ == "__main__": l = [test()] * 5 for i in l: i.request() for i in l: i.process() 
    • 为了能够并行(应该是并行吧),所以把 Popen 构造函数和 communicate()放在两个类方法里
    • 这样似乎导致了 communicate 的时候子进程已经终止,PIPE 关闭了( I/O operation on closed file.)读不到 stdout
    • 有什么办法可以弥补么?或者应该换一种写法?
    • 大概有 500 个 test 对象
    第 1 条附言    2022-04-12 23:55:13 +08:00
    • 如果不用类的写法,把两个类方法直接放到对应的两个循环里一点问题都没有
    第 2 条附言    2022-04-13 00:06:54 +08:00
    def request(): return subprocess.Popen(['pwsh' ,'-Command' ,'ping', '127.0.0.1'], stdout=subprocess.PIPE, encoding='gbk') def process(p): p.communicate()[0] if __name__ == "__main__": pool= [] for _ in range(5): pool.append(request()) for p in pool: process(p) 
    • 这样是并行的,也不会报错
    • 为什么经过了类,PIPE就关闭了
    8 条回复    2022-04-13 00:35:48 +08:00
    lolizeppelin
        1
    lolizeppelin  
       2022-04-12 23:27:08 +08:00
    subprocess 不长建议你好好读一下,本质上都会用到系统函数进行父子进程互交,win/linux 还不一样。
    ppj
        2
    ppj  
       2022-04-12 23:52:54 +08:00
    建议加数据 data 的获取和 p 放在 request 里,数据处理放在 process 里。
    eccentric579
        3
    eccentric579  
    OP
       2022-04-12 23:59:17 +08:00
    @ppj data 是用 communicate()阻塞获取的,放在一起不能并行
    SenLief
        4
    SenLief  
       2022-04-13 00:11:38 +08:00
    为什么是构造 test 类,这并行的是把那个 pwsh 运行 500 次吗?
    ec0
        5
    ec0  
       2022-04-13 00:12:06 +08:00   1
    [test()] * 5 相当于
    t = test()
    [t, t, t, t, t] 也就是说 list 里的是同一个 t ,对同一个 t 多次调用 communication 自然会报错

    改成 [test() for i in range(5)] 这样生成的才是 5 个不一样的对象
    imycc
        6
    imycc  
       2022-04-13 00:32:42 +08:00   1
    [test()] * 5 有问题,都是同一个实例

    (假设你要 ping 的地址是实例化的参数,那更容易理解 [test(ip)] *5 这样错在哪里了
    eccentric579
        7
    eccentric579  
    OP
       2022-04-13 00:33:08 +08:00
    @ec0 万分感谢,我自己一天都不一定能想到这里出错了
    eccentric579
        8
    eccentric579  
    OP
       2022-04-13 00:35:48 +08:00
    @SenLief
    只是为了测试并行,所以没有给对象初始化赋值

    @imycc
    是啊是啊,只是想偷个懒的,结果把自己绕进去了
    关于     帮助文档     自助推广系统     博客     API     FAQ     Solana     3004 人在线   最高记录 6679       Select Language
    创意工作者们的社区
    World is powered by solitude
    VERSION: 3.9.8.5 24ms UTC 13:36 PVG 21:36 LAX 06:36 JFK 09:36
    Do have faith in what you're doing.
    ubao snddm index pchome yahoo rakuten mypaper meadowduck bidyahoo youbao zxmzxm asda bnvcg cvbfg dfscv mmhjk xxddc yybgb zznbn ccubao uaitu acv GXCV ET GDG YH FG BCVB FJFH CBRE CBC GDG ET54 WRWR RWER WREW WRWER RWER SDG EW SF DSFSF fbbs ubao fhd dfg ewr dg df ewwr ewwr et ruyut utut dfg fgd gdfgt etg dfgt dfgd ert4 gd fgg wr 235 wer3 we vsdf sdf gdf ert xcv sdf rwer hfd dfg cvb rwf afb dfh jgh bmn lgh rty gfds cxv xcv xcs vdas fdf fgd cv sdf tert sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf sdf shasha9178 shasha9178 shasha9178 shasha9178 shasha9178 liflif2 liflif2 liflif2 liflif2 liflif2 liblib3 liblib3 liblib3 liblib3 liblib3 zhazha444 zhazha444 zhazha444 zhazha444 zhazha444 dende5 dende denden denden2 denden21 fenfen9 fenf619 fen619 fenfe9 fe619 sdf sdf sdf sdf sdf zhazh90 zhazh0 zhaa50 zha90 zh590 zho zhoz zhozh zhozho zhozho2 lislis lls95 lili95 lils5 liss9 sdf0ty987 sdft876 sdft9876 sdf09876 sd0t9876 sdf0ty98 sdf0976 sdf0ty986 sdf0ty96 sdf0t76 sdf0876 df0ty98 sf0t876 sd0ty76 sdy76 sdf76 sdf0t76 sdf0ty9 sdf0ty98 sdf0ty987 sdf0ty98 sdf6676 sdf876 sd876 sd876 sdf6 sdf6 sdf9876 sdf0t sdf06 sdf0ty9776 sdf0ty9776 sdf0ty76 sdf8876 sdf0t sd6 sdf06 s688876 sd688 sdf86