如何在Python异步函数中调用耗时的同步阻塞代码？-Python教程-PHP中文网

因为python异步事件循环是单线程协作式调度，直接调用同步阻塞函数（如time.sleep、requests.get）会卡住整个event loop，导致所有协程停摆；正确做法是用loop.run_in_executor将其移交线程池执行，i/o密集型用默认threadpoolexecutor，cpu密集型须显式传processpoolexecutor，并必须await等待结果。

如何在python异步函数中调用耗时的同步阻塞代码？

为什么不能直接在 `async def` 里调用同步阻塞函数？

因为 Python 的异步事件循环（如 asyncio）是单线程协作式调度的，一旦执行了像 time.sleep(10)、requests.get() 或文件读写这类同步阻塞操作，整个 event loop 就会被卡住，其他协程全部停摆——哪怕你只在一个 async def 里写了一行阻塞代码，效果等同于“全协程瘫痪”。

常见错误现象：RuntimeWarning: coroutine 'xxx' was never awaited 不是主因；更隐蔽的是 CPU 占用低但响应彻底停滞，监控发现 asyncio 任务堆积、超时频发，却查不到明显异常。

用 `loop.run_in_executor()` 把阻塞调用扔进线程池

这是最通用、最稳妥的解法：让阻塞操作在独立线程中运行，不干扰 event loop。默认使用 concurrent.futures.ThreadPoolExecutor，对 I/O 类阻塞（HTTP 请求、数据库查询、文件读写）效果极佳。

提示词大师-python版

图片提示词生成器？不止如此。马甲系统 —— 把脑海中的画面，翻译成AI能理解的专业表达。用得越多，它越懂你：首次需要多问几句确认方向，用久了几乎一说就懂。用得越多，它越快：缓存机制让后续对话越来越省。 RAG进化：成功案例持续入库，越跑越聪明。输入「新手指南」查看完整功能介绍

下载

必须显式获取当前 event loop：asyncio.get_running_loop()（Python 3.7+），不能用 asyncio.get_event_loop() 在非主线程调用
不要自己创建新线程或进程——run_in_executor 已封装资源复用和异常传递逻辑
传入的函数必须是普通同步函数，不能是协程对象；参数直接按位置/关键字传，无需包装
返回值会自动被包装成 awaitable，可直接 await

import asyncio
import time
<p>def blocking_io():
time.sleep(2)  # 模拟耗时同步操作
return "done"</p><p>async def main():
loop = asyncio.get_running_loop()
result = await loop.run_in_executor(None, blocking_io)
print(result)  # 输出 "done"
</p>

什么情况下该换 `ProcessPoolExecutor`？

当同步代码是 CPU 密集型（比如科学计算、图像处理、加密解密），且 GIL 成为瓶颈时，线程池无济于事——此时需进程池绕过 GIL。但注意：进程间通信开销大、无法共享内存状态、序列化限制多（函数必须可 pickle）。

显式传入 concurrent.futures.ProcessPoolExecutor 实例，不能传 None
被调用函数及其所有依赖必须定义在模块顶层，不能是嵌套函数或 lambda
避免频繁小任务调度——启动进程成本高，适合单次 >100ms 的重计算
Windows 下需加 if __name__ == "__main__": 保护，否则可能递归 spawn 进程

别碰 `asyncio.to_thread()`（Python 3.9+）的几个现实限制

这个新 API 看似更简洁：await asyncio.to_thread(blocking_io)，但它只是 run_in_executor 的语法糖，底层仍用线程池——所以线程安全、异常传播、资源限制等问题一个没少。

它不解决 GIL，CPU 密集型任务依然无效
无法控制线程池大小，默认最大线程数是 min(32, os.cpu_count() + 4)，高并发场景下可能撑爆系统
无法复用已有 executor，每次调用都走默认池，不适合需要定制线程行为（如设置 daemon、timeout）的场景
Python 3.8 及以下版本不可用，线上环境兼容性需额外验证

真正容易被忽略的点：阻塞函数内部如果又调用了另一个异步函数（比如误把 await some_async_func() 写在同步函数里），run_in_executor 会直接抛 RuntimeError: no running event loop——这种嵌套调用必须彻底剥离，不能靠“扔进线程就万事大吉”。