事件循环是python异步编程的核心机制，负责调度和运行协程。1. asyncio.run() 是启动事件循环的推荐方式，适用于大多数情况；2. 在需手动获取事件循环时，应优先使用 asyncio.get_running_loop()；3. 事件循环通过“就绪队列”管理任务，在 await 遇到 i/o 等待时切换任务以实现并发；4. 使用 create_task() 将协程封装为任务提交给事件循环执行；5. 避免阻塞主线程，可用 loop.run_in_executor() 处理同步阻塞或cpu密集型任务；6. 多线程中需为每个线程绑定独立事件循环。正确理解并应用这些机制，有助于编写高效稳定的异步程序。
python 的异步编程在处理高并发、I/O 密集型任务时非常有用，而 asyncio 是 Python 官方提供的异步框架。理解它的事件循环机制是掌握异步编程的关键。
什么是事件循环？
事件循环（Event Loop）是 asyncio 的核心，它负责调度和运行协程。你可以把它想象成一个无限循环，不断检查是否有任务需要执行，并在合适的时候调度它们。
在 Python 3.7+ 中，通常使用 asyncio.run() 来启动主函数，它会自动创建并管理事件循环。但如果你需要更细粒度的控制，比如在 jupyter 或某些嵌入式环境中，可能需要手动获取或创建事件循环。
立即学习“Python免费学习笔记（深入）”；
例如：
import asyncio async def main(): print("Hello") await asyncio.sleep(1) print("World") asyncio.run(main())
在这个例子中，asyncio.run() 启动了事件循环，然后把 main() 协程加入其中，事件循环会负责调度它的执行。
如何正确获取和使用事件循环？
在某些情况下，你可能需要手动获取当前的事件循环。比如，在 Jupyter Notebook 中直接使用 asyncio.run() 可能会报错，因为事件循环已经存在。
常见的做法是使用以下方式之一来获取事件循环：
- 在主线程中：loop = asyncio.get_event_loop()
- 在子线程中：loop = asyncio.new_event_loop()
- 推荐（适用于大多数情况）：loop = asyncio.get_running_loop()
需要注意的是：
- get_event_loop() 已逐渐不推荐使用，尤其是在 Python 3.9+ 中。
- get_running_loop() 更安全，但如果不在事件循环内部调用会抛出异常。
事件循环是如何调度任务的？
事件循环并不是一上来就把所有协程都跑完，而是通过“事件”驱动的方式进行调度。
举个简单的例子：
async def task1(): print("Task1 started") await asyncio.sleep(2) print("Task1 done") async def task2(): print("Task2 started") await asyncio.sleep(1) print("Task2 done") async def main(): t1 = asyncio.create_task(task1()) t2 = asyncio.create_task(task2()) await t1 await t2 asyncio.run(main())
在这个例子中，task1 和 task2 被同时提交给事件循环。当其中一个遇到 await asyncio.sleep() 时，事件循环会切换到另一个任务继续执行，从而实现并发效果。
关键点在于：
- 使用 create_task() 把协程封装成任务并交给事件循环。
- await 某个任务表示等待它完成，但期间可以调度其他任务。
- 事件循环内部维护了一个“就绪队列”，每次从队列中取出任务执行。
常见问题与注意事项
不要混用不同的事件循环库
比如，不要在同一程序中混用 asyncio 和 tornado 的事件循环，除非你清楚自己在做什么。否则容易导致死锁或调度混乱。
避免阻塞主线程
如果你在事件循环中执行同步阻塞操作（如长时间计算、普通 time.sleep()），整个异步流程都会被卡住。解决办法是：
- 使用 await asyncio.sleep() 替代 time.sleep()
- 对于 CPU 密集任务，考虑用 loop.run_in_executor() 放到线程或进程中执行
def blocking_function(): time.sleep(5) return "Done" async def main(): loop = asyncio.get_running_loop() result = await loop.run_in_executor(None, blocking_function) print(result) asyncio.run(main())
注意多线程中的事件循环
如果你在一个非主线程中使用事件循环，记得先为该线程绑定一个新的事件循环：
import threading def thread_main(): loop = asyncio.new_event_loop() asyncio.set_event_loop(loop) loop.run_until_complete(main()) threading.Thread(target=thread_main).start()
否则可能会出现找不到事件循环的问题。
基本上就这些。事件循环虽然看起来复杂，但只要理解它是如何调度协程、如何避免阻塞，以及在不同环境下如何正确使用，就能比较顺利地写出高效的异步代码了。
