Python中asyncio协程是如何实现主动调度的？

在Python的asyncio里，协程的主动调度核心是靠事件循环（Event Loop）和await表达式。简单说，当一个协程执行到await某个可等待对象（比如另一个协程、Task或Future）时，它就会主动挂起自己，把控制权交还给事件循环。事件循环接着去执行其他就绪的任务，等原来那个await的东西有结果了，事件循环再在合适的时机把挂起的协程唤醒继续跑。

关键点就这几个：

1. await是调度点：代码里一遇到await，当前协程就暂停，事件循环接管。
2. 事件循环是调度器：它维护着待执行的任务队列（比如asyncio.create_task()创建的Task）。当一个任务在await时，事件循环就从队列里找其他可运行的任务来执行。
3. Task封装协程：直接用await coro()是顺序执行。用asyncio.create_task(coro())会把协程包装成Task，这个Task会被事件循环管理，从而实现并发。多个Task在遇到await时就能互相切换。
4. 底层靠yield和控制流反转：协程函数本质是生成器，await有点像yield from。挂起时保存现场（局部变量、程序计数器），恢复时再加载回来。

看个简单例子就明白了：

import asyncio

async def say_after(delay, what):
    await asyncio.sleep(delay)  # 遇到await，挂起当前协程，让事件循环去干别的
    print(what)

async def main():
    # 创建两个Task，它们会被事件循环并发调度
    task1 = asyncio.create_task(say_after(1, 'hello'))
    task2 = asyncio.create_task(say_after(2, 'world'))

    await task1  # 等待task1完成，但此时事件循环可以调度task2
    await task2  # 等待task2完成

asyncio.run(main())

这里asyncio.sleep()模拟I/O等待。执行时，两个say_after协程都被包装成Task。当task1在sleep(1)时挂起，事件循环就转去执行task2的sleep(2)。虽然看起来是同时“等”，但只有一个线程，靠的就是在await点主动让出控制权。

所以，asyncio的主动调度就是协程在await时主动让出，由事件循环决定接下来跑谁。想实现并发，记得把协程包装成Task。

一句话建议：用create_task把协程扔给事件循环，然后在await点自然就会切换。

不一定会切换到主循环的协程

有可能是 release 的时候直接切换到 lock 的协程

看你怎么用的 原理就那样

你可以简单理解为未结束的协程之间 goto 来 goto 去