Python异步任务调度的核心是事件循环,它作为单线程任务调度器,通过协作式并发高效处理I/O密集型任务;事件循环监听I/O、调度协程、管理Task与Future,需显式启动,且每线程至多一个运行中实例。

Python异步任务调度的核心是事件循环(Event Loop),它不是“多线程”或“多进程”的替代品,而是通过单线程协作式并发,高效处理大量I/O密集型任务。理解事件循环的运行机制,是写出可靠异步代码的前提。
事件循环是什么:单线程上的任务调度器
事件循环是一个持续运行的主循环,负责监听I/O事件(如网络响应、文件读写完成)、调度协程(coroutine)执行、管理任务(Task)和未来对象(Future)。它不自动启动,需显式调用 asyncio.run() 或手动创建并运行。
- 每个线程最多只能有一个正在运行的事件循环(主线程默认可获取一个)
- asyncio.run(coro) 会新建一个事件循环、运行协程、等其结束、然后关闭循环——适合脚本入口
- 在已运行的循环中(如Web服务器内部),不能再次调用 run(),否则报 RuntimeError: asyncio.run() cannot be called from a running event loop
任务(Task)与协程(Coroutine)的区别
协程对象(coro)只是可等待(awaitable)的函数返回值,本身不执行;而 Task 是被事件循环调度执行的“活跃单元”,是对协程的封装和调度包装。
- 用 asyncio.create_task(coro) 将协程提交给当前事件循环,立即安排执行(但不一定立刻运行)
- 直接 await coro 是同步等待,会阻塞当前协程,直到该协程完成
- 多个 create_task 可实现真正的并发:它们在事件循环中交替推进,共享同一线程
事件循环如何推进任务:一次tick的典型流程
事件循环每轮(tick)大致做三件事:检查已完成的I/O、执行就绪的回调、切换协程状态。这不是时间片轮转,而是基于“等待—就绪”驱动的协作模型。
立即学习“Python免费学习笔记(深入)”;
- 遇到 await asyncio.sleep(1) 或 await aiohttp.get(...),当前协程挂起,控制权交还事件循环
- 事件循环去检查其他任务是否就绪(例如另一个请求已收到响应),或等待系统通知(如socket就绪)
- I/O完成时,对应Future被设为done,关联的Task被重新标记为“可运行”,下次循环tick中恢复执行
常见误区与调试建议
很多异步问题源于对事件循环生命周期或任务调度时机的误判。
- 在同步函数里调用 asyncio.run() 多次 → 每次都新建/关闭循环,开销大且无法共享状态;应改为复用循环或使用 asyncio.create_task() 在已有循环中调度
- 忘记 await 一个协程 → 得到的是协程对象而非结果,后续可能报 RuntimeWarning: coroutine 'xxx' was never awaited
- 用 time.sleep() 替代 asyncio.sleep() → 整个事件循环被阻塞,所有并发失效
- 调试时可用 asyncio.all_tasks() 查看当前循环中还有哪些Task未完成,辅助定位“遗漏await”或“任务泄漏”
事件循环不是黑盒,它是可观察、可干预、可嵌入的。掌握它的调度逻辑,才能把 async/await 从语法糖变成真正高效的工具。










