asyncio.create_task() 是在当前协程中插入新异步任务的标准方式,它将协程包装为task并注册到事件循环就绪队列,触发微任务调度;需在运行中的事件循环上下文中调用,不可跨线程或脱离循环。

可以在当前协程中直接调用 asyncio.create_task(),把新任务提交到事件循环的就绪队列,它会自动进入微任务调度流程——不需要手动操作微任务队列本身。
微任务队列不对外暴露,但可通过 create_task 触发调度
Python 的 asyncio 并未提供直接访问或修改微任务队列(microtask queue)的 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 —— 那里没有运行中的事件循环;如需异步能力,应通过 asyncio.run_coroutine_threadsafe() 提交到主线程循环
- 同步函数里不能直接 create_task;必须先获取运行中的循环:
asyncio.get_running_loop().create_task(...)
和普通队列的区别:这不是“排队”,而是“注册+调度”
微任务调度不依赖 FIFO 队列 push/pop,而是靠事件循环维护的内部就绪任务列表。create_task 不是往某个公开队列里塞东西,而是告诉事件循环:“这个协程已就绪,下次轮到微任务时请调度它”。因此不存在“中途插队”或“优先级调整”的接口——所有微任务都享有同等调度优先级,且总在当前宏任务结束后立即批量执行。











