有两段代码，是关于 asyncio 的。
代码段一：
import asyncio async def worker_1(): print('worker_1 start') await asyncio.sleep(1) print('worker_1 done') async def worker_2(): print('worker_2 start') await asyncio.sleep(2) print('worker_2 done') async def main(): print('before await') await worker_1() print('awaited worker_1') await worker_2() print('awaited worker_2') %time asyncio.run(main()) ########## 输出 ########## before await worker_1 start worker_1 done awaited worker_1 worker_2 start worker_2 done awaited worker_2 Wall time: 3 s 代码段二：
import asyncio async def worker_1(): print('worker_1 start') await asyncio.sleep(1) print('worker_1 done') async def worker_2(): print('worker_2 start') await asyncio.sleep(2) print('worker_2 done') async def main(): task1 = asyncio.create_task(worker_1()) task2 = asyncio.create_task(worker_2()) print('before await') await task1 print('awaited worker_1') await task2 print('awaited worker_2') %time asyncio.run(main()) ########## 输出 ########## before await worker_1 start worker_2 start worker_1 done awaited worker_1 worker_2 done awaited worker_2 Wall time: 2.01 s 问题：代码段一里面的协程(coroutine)换成代码段二的任务(task)后，为什么执行顺序就变了？这个过程中发生了什么事情？
说说我的猜想：
发现调用 asyncio.run(main()) 或者 [asyncio.gather()->asyncio.get_event_loop()->loop.run_until_complete()]都会将一个 coroutine 转化成 task/future 再放 event loop 里面去， 交由 event loop 去管理这些 task/future。代码段一只将 main()这个 coroutine 封装成了 task 加入到 event loop 中，所以整个 event loop 中只有一个 task 在走，在这个 task 中代码是顺序执行的，所以最后呈现出同步执行的结果；
但是代码段二调用了两次 asyncio.create_task()，这个方法会将一个 coroutine 转换成一个 task 并且放到 event loop 中，所以整个 event loop 其实有三个 task （ main，task1，task2 ），之后程序就交给 event loop 来调度，执行顺序就变不同了。 这个假设目前来看好像能解释得通
最后，希望各位能指点一下~
1
Select Language