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_coroasyncio.gather
2. 为什么我们必须这样做await slow_task？
3. 为什么Awaiting Slow在协程似乎已经启动后打印？
4. 什么才是真正的任务？我知道gather正在做的是安排 任务。并且create_task据说创建了一个任务。

一个深入的答案将不胜感激。谢谢！

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

Answer 1

有什么作用asyncio.create_task()？

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

它是 asyncio 的核心原语之一，相当于启动线程的 asyncio。（在同一个类比中，等待任务await相当于加入一个线程。）

不应该slow_task是不能运行，直到完成fast_coro

不，因为您明确地习惯于在后台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正是这样做的：将其提交给事件循环以与其他任务同时执行，切换点是 any await。

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

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

为什么我们要等待slow_task？

我们不具备时，它只是用来等待协同程序都干净完成。代码也可以等待asyncio.sleep()或类似的东西。main()立即从（和事件循环）返回一些任务仍然未决也可以工作，但它会打印一条警告消息，表明可能存在错误。在停止事件循环之前等待（或取消）任务更简洁。

什么才是真正的任务？

它是一个 asyncio 构造，用于跟踪具体事件循环中协程的执行。当您调用 时create_task，您提交一个协程以供执行并收到一个句柄。您可以在实际需要结果时等待此句柄，或者如果您不关心结果，则永远无法等待它。这个句柄是task，它继承自Future，这使得它可以等待并且还提供了基于回调的低级接口，例如add_done_callback.