Python Asyncio - 等待条件满足的 Pythonic 方式

Question

我需要等到某个条件/方程式在 python 的异步函数中变为 True。 基本上它是一个标志变量，将由运行在 asyncio.create_task() 中的协程标记。我想等待，直到它在 asyncio 的主循环中被标记。 这是我当前的代码：

import asyncio
flag = False

async def bg_tsk():
    await asyncio.sleep(10)
    flag = True

async def waiter():
    asyncio.create_task(bg_tsk())
    await asyncio.sleep(0)
    # I find the below part unpythonic
    while not flag:
        await asyncio.sleep(0.2)

asyncio.run(waiter())

有没有更好的实现方式？或者这是最好的方法吗？我曾尝试使用“asyncio.Event”，但它似乎不适用于“asyncio.create_task()”。

Answer 1

asyncio.Event 的使用非常简单。示例如下。

注意：应该从协程内部创建事件才能正常工作。

import asyncio


async def bg_tsk(flag):
    await asyncio.sleep(3)
    flag.set()


async def waiter():
    flag = asyncio.Event()
    asyncio.create_task(bg_tsk(flag))
    await flag.wait()
    print("After waiting")


asyncio.run(waiter())