你在编写异步任务时，有时需要在执行中途插入一个额外的任务——比如日志上报或状态通知，同时又不希望主流程等待。这时最直接的方式就是使用 asyncio.create_task()。它会将新协程封装成 Task，直接放入事件循环的就绪队列，随后由微任务调度机制自动处理。你无需手动操作微任务队列，因为 Python 并未对外暴露该队列的接口。
简单来说，所谓“中途插入新异步任务”，本质就是让新协程尽快获得调度机会。微任务的执行机制是：每次宏任务（例如一个 await 返回）结束后，事件循环会一次性清空所有待处理的微任务。而 create_task() 的作用，就是将协程注册为一个“已就绪”的 Task，等待下一轮微任务轮转时被拉出执行。
微任务队列不对外公开，但可通过 create_task 触发调度
你可能会好奇：能否直接向微任务队列中 push 一个回调？答案是否定的。asyncio 并未提供这样的 API。不过，有几种变通方法可以实现“中途插入”的效果：
- create_task() 是标准做法：将协程打包成 Task，交给事件循环的内部就绪列表，这部分属于微任务级别的调度。
- await asyncio.sleep(0) 是一个小技巧：主动让出当前协程的控制权，强制事件循环检查并执行所有已就绪的微任务——刚刚通过 create_task 提交的任务会在这个时刻得到执行。
- 千万不要使用 await 直接等待新协程：那样会变成串行执行，当前协程会阻塞直至新协程完成，完全丧失了“中途插入”的并发意义。
常见插入场景与写法示例
举个例子。假设你在处理一个耗时 I/O 操作，中间希望触发一次日志上报：
- 错误写法：
await log_async("started")—— 当前协程阻塞，等待日志写完后才能继续。 - 正确写法：
asyncio.create_task(log_async("started"))—— 日志任务立即注册，主流程继续向下执行。 - 如果你希望日志任务在下一步开始前就启动（但不需等待它完成），可以在后面添加一句
await asyncio.sleep(0)，让事件循环利用这个间隙将刚注册的任务调度出去。
注意边界：不能跨线程、不能脱离事件循环
create_task 只能在正在运行的事件循环上下文中调用，这是必须遵守的规则：
- 在主线程中，使用 asyncio.run() 启动后，任意 async 函数内部都能安全调用 create_task。
- 如果代码运行在子线程中，那里没有正在运行的事件循环，不能直接调用 create_task。若需提交任务到主线程的循环，应使用 asyncio.run_coroutine_threadsafe()。
- 在同步函数中同样不能直接调用。需要先获取当前运行中的循环对象：
asyncio.get_running_loop().create_task(...)。
与普通队列的区别：这不是“排队”，而是“注册+调度”
很多人会下意识地将微任务队列想象成一个 FIFO 队列——push 进去再 pop 出来。实际上并非如此。事件循环内部维护的是一个“就绪任务列表”，create_task 并非向某个公开队列中塞入元素，而是告诉事件循环：“这个协程已经就绪，下次轮到微任务时请安排它执行。” 所有微任务在调度优先级上是平等的，并不存在“中途插队”或“优先级调整”的公开接口。它们统一在当前宏任务结束后批量执行。因此，不必试图手动控制微任务顺序——asyncio 的设计哲学就是让事件循环自主管理，你只需将任务注册进去即可。
