如何编写同步和异步代码的类实例化形式？

Question

我正在尝试构建一个可从“标准”（即：非 asyncio）代码和 asyncio 协程实例化的类。

特别是一些方法需要产生subprocesses 并等待完成。 不同之处在于，当子进程运行时，我不应该阻塞整个程序（其他协程，如果存在，应该能够运行）。

这归结为使用plain：

from subprocess import run
r = run(arg[0], args)

在“标准”代码中：

from asyncio import create_subprocess_exec
r = await create_subprocess_exec(*args)
t = await r.wait()

问题是我不能从标准的非async 方法await 即使循环正在运行（我可以测试循环是否正在运行以区分，但我不知道如何挂钩到正在运行的循环，如果有的话）。

Answer 1

asyncio 不支持您想要做的事情，而且可能根本不可能。同步和异步函数不仅在函数名称上有所不同，而且在值和函数调用的基本语义上也有所不同。

表面上你可以这样做：

def _run_subprocess_sync(args):
    from subprocess import run
    return run(args[0], args)

async def _run_subprocess_async(args):
    from asyncio import create_subprocess_exec
    r = await create_subprocess_exec(*args)
    return await r.wait()

def run_subprocess(args):
    if asyncio.get_event_loop() is not None and asyncio.get_event_loop().is_running():
        return _run_subprocess_async(args)
    else:
        return _run_subprocess_sync(args)

请注意，在异步情况下，run_subprocess 不会等待对_run_subprocess_async 的调用，因为它会返回一个协程对象，它的调用者（可能是一个async def 函数）将等待。

问题是这种方法不会让你走得太远，因为它需要在层次结构的每一层都使用类似的ifs。例如，如果您有一个函数调用 run_subprocess 并对其结果进行处理，那么它同样必须有两个变体，一个同步和一个异步，以及在两者之间切换。