是的,async函数中执行cpu密集型逻辑会阻塞单线程事件循环,导致所有协程无法调度;必须用processpoolexecutor剥离计算,并注意gil、序列化、ipc开销及结果处理瓶颈。

因为 async 函数一旦执行 CPU 密集型逻辑,就会阻塞整个事件循环,所有其他协程都得等着——异步并发能力直接归零。
async 函数里做计算会卡住事件循环
asyncio 的事件循环是单线程的,靠协作式调度。只要某个协程不主动 await,它就一直霸占 CPU,别的协程根本没机会运行。
- 比如在
async def里写sum(range(10**8))或矩阵运算,这几十毫秒甚至几百毫秒内,整个服务对网络请求、数据库查询、定时任务全部无响应 - 现象是:QPS 断崖下跌、超时激增、监控显示事件循环延迟(
loop.time()和实际耗时不匹配) - 和用
time.sleep(5)卡住一样严重——只是后者明显,前者容易被误认为“只是慢一点”
为什么不能用 asyncio.run_in_executor 简单包一层就完事?
能包,但不是“随便包”,很多写法反而引入新问题:
-
run_in_executor(None, ...)默认走ThreadPoolExecutor,而 CPU 密集型任务在线程池里跑,受 GIL 限制,多线程并行效果极差 - 正确做法必须用
ProcessPoolExecutor,但要注意:if __name__ == "__main__":在 Windows 上不是可选项,而是硬性要求,否则子进程启动失败 - 函数必须定义在模块顶层(不能是类方法、闭包或 lambda),否则序列化失败,报
PicklingError - 大量小任务反复提交给进程池,IPC 开销可能比计算本身还高;应尽量批量处理,避免单个数字反复调用
怎么判断一段逻辑是否适合放 async 函数里?
看它有没有真正意义上的「等待点」:
- 有
await调用(如aiohttp.ClientSession.get()、asyncpg.fetch())→ 安全 - 只有纯 Python 循环、数学运算、字符串处理、字典遍历 → 不适合,应剥离出去
- 调用了 C 扩展但内部仍做大量计算(如某些 NumPy 操作未释放 GIL)→ 表面快,实则仍阻塞,需实测
threading.current_thread().ident是否变化
最常被忽略的一点:即使你把计算逻辑抽出去用 ProcessPoolExecutor,如果结果要反序列化回主进程再做大量 JSON 序列化或模板渲染,这部分又变成新的 CPU 瓶颈——异步不是魔法,它只解决「等待」,不加速「算」。
Python免费学习笔记(深入):立即使用
在学习笔记中,你将探索 Python 的核心概念和高级技巧!











