python - 将任务添加到运行循环并运行直到完成

Question

我有一个从 async 函数调用的函数，没有 await，我的函数需要调用 async 函数。我可以使用 asyncio.get_running_loop().create_task(sleep()) 执行此操作，但顶层的 run_until_complete 在新任务完成之前不会运行。

如何让事件循环运行直到新任务完成？

我不能让我的函数async因为它不是用await调用的。

我无法改变 future 或 sleep 。我只控制 in_control。

import asyncio


def in_control(sleep):
    """
    How do I get this to run until complete?
    """
    return asyncio.get_running_loop().create_task(sleep())


async def future():
    async def sleep():
        await asyncio.sleep(10)
        print('ok')

    in_control(sleep)


asyncio.get_event_loop().run_until_complete(future())

Answer 1

看来包裹nest_asyncio会在这里帮助你。我还在示例中包含了获取任务的返回值。

import asyncio
import nest_asyncio


def in_control(sleep):
    print("In control")
    nest_asyncio.apply()
    loop = asyncio.get_running_loop()
    task = loop.create_task(sleep())
    loop.run_until_complete(task)
    print(task.result())
    return


async def future():
    async def sleep():
        for timer in range(10):
            print(timer)
            await asyncio.sleep(1)
        print("Sleep finished")
        return "Sleep return"

    in_control(sleep)
    print("Out of control")


asyncio.get_event_loop().run_until_complete(future())

结果:

In control
0
1
2
3
4
5
6
7
8
9
Sleep finished
Sleep return
Out of control
[Finished in 10.2s]