非阻塞子进程执行
要实现非阻塞子进程执行,请考虑使用 subprocess.Popen 而不是 subprocess.call。 subprocess.call 等待命令完成后再返回,而 subprocess.Popen 立即启动子进程并返回一个类似文件的对象。
<code class="python">import subprocess subprocess.Popen(["python", "slave.py"] + sys.argv[1:])</code>
通过使用 subprocess.Popen,您可以将参数传递给 Slave。 py 并允许它独立于 main.py 运行。然后,slave.py 可以在不阻塞 main.py 的情况下执行其任务。
<code class="python">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)</code>
在 Python 3.5 及更高版本中,您还可以使用协程来实现并行性和非阻塞子进程执行。
<code class="python">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()</code>
以上是如何在Python中实现非阻塞子进程执行?的详细内容。更多信息请关注PHP中文网其他相关文章!