推荐学习书目
› 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
这是一个创建于 947 天前的主题，其中的信息可能已经有所发展或是发生改变。
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
 |
1
lolizeppelin 2022-04-12 23:27:08 +08:00
subprocess 不长建议你好好读一下,本质上都会用到系统函数进行父子进程互交,win/linux 还不一样。
|
 |
2
ppj 2022-04-12 23:52:54 +08:00
建议加数据 data 的获取和 p 放在 request 里，数据处理放在 process 里。
|
 |
3
eccentric579 OP @ppj data 是用 communicate()阻塞获取的，放在一起不能并行
|
 |
4
SenLief 2022-04-13 00:11:38 +08:00
为什么是构造 test 类，这并行的是把那个 pwsh 运行 500 次吗？
|
 |
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 个不一样的对象 |
 |
6
imycc 2022-04-13 00:32:42 +08:00 1
[test()] * 5 有问题，都是同一个实例
（假设你要 ping 的地址是实例化的参数，那更容易理解 [test(ip)] *5 这样错在哪里了 |
|
7
eccentric579 OP @ec0 万分感谢，我自己一天都不一定能想到这里出错了
|
|
8
eccentric579 OP |
Select Language