首页  >  文章  >  后端开发  >  如何在Python中实现非阻塞子进程执行?

如何在Python中实现非阻塞子进程执行?

Linda Hamilton
Linda Hamilton原创
2024-10-19 13:47:02209浏览

How to Achieve Non-Blocking Subprocess Execution in Python?

非阻塞子进程执行

要实现非阻塞子进程执行,请考虑使用 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中文网其他相关文章!

声明:
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn