不死心，再来问一遍关于 Python 的 asyncio 问题

有两段代码，是关于 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 来调度，执行顺序就变不同了。这个假设目前来看好像能解释得通

最后，希望各位能指点一下~

dbow

2019-07-22 18:32:13 +08:00

await 协程时, 协程才会开始执行，执行返成结果返回给 await
create_task 时会先直接 await 协程，相当于 task = await 协程; await task，由于你两个 create_task 是连在一起的，它们就没有顺序关系，直接开始交错执行了。

看官方文档， https://docs.python.org/zh-cn/3/library/asyncio-task.html
asyncio.create_task(coro)
将 coro 协程打包为一个 Task 排入日程准备执行。返回 Task 对象。

该任务会在 get_running_loop() 返回的循环中执行，如果当前线程没有在运行的循环则会引发 RuntimeError。