asyncio.create_task() 做什么？

Question

asyncio.create_task() 是做什么的？我查看了文档，似乎无法理解。让我困惑的一段代码是这样的：

import asyncio

async def counter_loop(x, n):
    for i in range(1, n + 1):
        print(f"Counter {x}: {i}")
        await asyncio.sleep(0.5)
    return f"Finished {x} in {n}"

async def main():
    slow_task = asyncio.create_task(counter_loop("Slow", 4))
    fast_coro = counter_loop("Fast", 2)

    print("Awaiting Fast")
    fast_val = await fast_coro
    print("Finished Fast")

    print("Awaiting Slow")
    slow_val = await slow_task
    print("Finished Slow")

    print(f"{fast_val}, {slow_val}")

asyncio.run(main())

这给出了以下输出：

001 | Awaiting Fast
002 | Counter Fast: 1
003 | Counter Slow: 1
004 | Counter Fast: 2
005 | Counter Slow: 2
006 | Finished Fast
007 | Awaiting Slow
008 | Counter Slow: 3
009 | Counter Slow: 4
010 | Finished Slow
011 | Finished Fast in 2, Finished Slow in 4

我不太明白这是如何工作的。

1. 不应该slow_task 直到完成后才能运行 fast_coro，因为它从未在 asyncio.gather 中使用过 方法？
2. 我们为什么要await slow_task？
3. 为什么在协程似乎已经启动后打印Awaiting Slow？
4. 什么是真正的任务？我知道gather 正在做的是安排一个 任务。 create_task 据说会创建一个任务。

我们将不胜感激。谢谢！

值得一提的是，我对 Futures 知之甚少。

Answer 1

asyncio.create_task() 是做什么的？

它提交协程以“在后台”运行，即与当前任务和所有其他任务同时运行，在await 点之间切换。它返回一个称为“任务”的可等待句柄，您也可以使用它来取消协程的执行。

它是 asyncio 的核心原语之一，相当于启动线程的 asyncio。 （同理，使用await 等待任务相当于加入线程。）

在fast_coro完成之前，slow_task是否应该无法运行

不，因为您明确使用create_task 在后台启动slow_task。你有没有写过类似的东西：

    slow_coro = counter_loop("Slow", 4)
    fast_coro = counter_loop("Fast", 2)
    fast_val = await fast_coro

...确实slow_coro 不会运行，因为还没有人将它提交给事件循环。但create_task 正是这样做的：将其提交到事件循环以与其他任务同时执行，切换点是任何await。

因为它从未在 asyncio.gather 方法中使用过？

asyncio.gather 并不是在 asyncio 中实现并发的唯一方法。它只是一个实用函数，可以更轻松地等待多个协程全部完成，并同时将它们提交到事件循环。 create_task 只是提交，它可能应该被称为 start_coroutine 或类似的名称。

我们为什么要等待slow_task？

我们没有必须这样做，它只是用来等待两个协程干净地完成。代码也可以等待asyncio.sleep() 或类似的东西。立即从main()（和事件循环）返回，而某些任务仍处于待处理状态也可以正常工作，但它会打印一条警告消息，指示可能存在错误。在停止事件循环之前等待（或取消）任务更简洁。

什么是真正的任务？

它是一个异步构造，用于在具体事件循环中跟踪协程的执行。当你调用create_task 时，你提交了一个协程来执行并接收一个句柄。当您真正需要结果时，您可以等待此句柄，或者如果您不关心结果，则永远不能等待它。这个句柄就是task，它继承自Future，使得它可以等待，并且还提供了基于回调的底层接口，例如add_done_callback。