Python asyncio.sleep 表现得像一个拦截器

在这里阻挡你的不是asyncio.sleep.那就是你们在你们的for循环中各await个协程store.这意味着literally在继续迭代之前，您要等待它完全执行.

如果您想安排每个协程immediately，而不是等待到finish，您可以在它们上使用asyncio.create_task.只要确保在some点等待所有任务即可.

以下是一个简化的示例:

from asyncio import create_task, gather, run, sleep


async def store(text: str, delay: bool = False) -> None:
    print(text)
    if delay:
        await sleep(5)


texts = [
    ("hi", False),
    ("how", False),
    ("are", False),
    ("you", True),
]


async def run_tests() -> None:
    last_finished: str | None = None
    tasks = []
    for text, delay in texts:
        tasks.append(create_task(store(text, delay=delay)))
        if not delay:
            last_finished = text
    await gather(*tasks)
    assert last_finished == "are"


if __name__ == "__main__":
    run(run_tests())

为了方便起见，我在这里用了asyncio.gather来等待最后的所有任务.

如果您使用的是Python>=3.11，则可以改用asyncio.TaskGroup上下文管理器:

from asyncio import TaskGroup, run, sleep

...

async def run_tests() -> None:
    last_finished: str | None = None
    async with TaskGroup() as task_group:
        for text, delay in texts:
            task_group.create_task(store(text, delay=delay))
            if not delay:
                last_finished = text
    assert last_finished == "are"

但我不得不说，您使用的变量命名有点令人困惑，因为last_finished表明最后是scheduled的协程(与"are"文本一起)也是最后done的协程.大体是not true个！

一旦调度了协同 routine ，就不能保证它将在其他调度的协同 routine 之前或之后完成，无论先调度的是哪一个.为了确保这一点，你必须使用某种形式的synchronization primitive.

根据实际环境，这可能特别重要，因为您谈论的是将内容写入数据库.但在这个超级简单的例子中，顺序很可能是正确的.