事件循环上计划的任务的执行顺序 (Python 3.10)

Question

我仍在学习 python 3.10 中的 asyncio 模块。下面是我编写的代码，试图了解如何在事件循环上将协程作为任务运行。我得到的输出与我的预期不同。请帮助我理解我做错了什么或者是否有什么我误解的地方。

import asyncio 
    async def f(x):
        try:
            print(f"Inside f({x})...")
            await asyncio.sleep(x)
            print(f'slept for {x} seconds!!')
            return x
        except asyncio.CancelledError:  # Execute this part only when the task is cancelled.
            print(f'Cancelled({x})')
    
    async def main():
        loop = asyncio.get_running_loop()
    
        task1 = loop.create_task(f(1), name="task1")
        task2 = loop.create_task(f(2), name="task2")
        task3 = loop.create_task(f(3), name="task3")
    
        print(task1.done())
        print(task2.done())
        print(task3.done())
    
    asyncio.run(main())

输出：

False False False 在 f(1) 内... 在 f(2) 内... 在 f(3) 内... 已取消(3) 已取消(1) 已取消(2)

我希望此代码在 print(task3.done()) 之后立即退出 main() ，并且仅运行协程函数 f 的异常处理部分(x)，但事件循环在实际退出之前恰好运行 f(1)、f(2) 和 f(3) 的功能一次。 我的疑问是

1. 为什么事件循环上的所有任务在取消之前都会运行一次？
2. 执行顺序是什么（如果有的话，是固定的还是随机的？）

编辑： 我首先尝试使用 task1 = asyncio.create_task(f(1), name = "task1")。然后我使用了loop.create_task()。两者都给出相同的输出（我猜这是预期的）。

Answer 1

我认为你应该将“task1 = loop.create_task(f(1), name="task1")”行更改为“task1 = asyncio.create_task(f(1), name="task1")”

Answer 2

您的程序在异步任务完成之前就已完成，因此它们都将被取消。对 done() 的调用只是打印出它们还没有完成。

如果您想让任务有机会完成，除了前面的答案之外，您还需要添加 await(task1) 等。或者只是
await asyncio.gather(task1, task2, task3) 在一次调用中等待所有这些任务。