使用 subprocess.call 执行外部脚本时,维护非阻塞工作流程对于避免主程序停顿至关重要。本文提出了实现此目标的综合解决方案。
执行非阻塞子进程的主要方法是使用 subprocess.Popen 而不是 subprocess.call。这种替代方案不会阻止主程序,允许主程序在子进程独立运行时继续其操作。下面是一个例子:
subprocess.Popen(["python", "slave.py"] sys.argv[1:])
有关非阻塞子流程调用的完整演示,请考虑以下代码:
import subprocess
import time
p = subprocess.Popen(['sleep', '5'])
while p.poll() is None:
print('Still sleeping')
time.sleep(1)
print('Not sleeping any longer. Exited with returncode %d' % p.returncode)
此代码异步执行 'sleep' 命令,定期检查其状态直至完成。
对于 Python 3.5 及更高版本,更现代、更高效的方法涉及使用 asyncio。它允许真正的并发,使多个任务能够同时执行。这是一个例子:
import asyncio
async def do_subprocess():
print('Subprocess sleeping')
proc = await asyncio.create_subprocess_exec('sleep', '5')
returncode = await proc.wait()
print('Subprocess done sleeping. Return code = %d' % returncode)
async def sleep_report(number):
for i in range(number 1):
print('Slept for %d seconds' % i)
await asyncio.sleep(1)
loop = asyncio.get_event_loop()
tasks = [
asyncio.ensure_future(do_subprocess()),
asyncio.ensure_future(sleep_report(5)),
]
loop.run_until_complete(asyncio.gather(*tasks))
loop.close()
这种方法确保子进程和主程序同时运行,从而最大限度地提高性能和响应能力。
免责声明: 提供的所有资源部分来自互联网,如果有侵犯您的版权或其他权益,请说明详细缘由并提供版权或权益证明然后发到邮箱:[email protected] 我们会第一时间内为您处理。
Copyright© 2022 湘ICP备2022001581号-3