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
我不太明白这是如何工作的。
slow_task
没有被用在asyncio.gather
方法中,为什么它能在fast_coro
完成之前运行?- 我们为什么需要
await slow_task
? - 为什么
Awaiting Slow
在协程启动后才打印出来? - 什么是一个 task?我知道
gather
所做的是调度一个 task,而create_task
则被认为是创建一个 task。
详细的答案将不胜感激。谢谢!
另外值得一提的是,我对 Futures 的了解非常有限。