asyncio协程不能直接做CPU密集计算，因其共享单线程和GIL，计算不主动让出控制权会卡死事件循环；须用asyncio.to_thread（线程池）或ProcessPoolExecutor（进程池）移出主线程。
asyncio 本身不处理 CPU 密集型任务，直接在协程里跑计算会卡死事件循环；必须把这类任务移出主线程，用 asyncio.to_thread() 或 loop.run_in_executor() 托管给线程池——但要注意，这只能缓解阻塞，不能突破 GIL 的并行限制。
为什么不能在协程里直接做 CPU 计算
asyncio 是单线程协作式并发，所有协程共享同一个线程和同一个 GIL。一旦某个协程执行纯计算（比如大数组排序、递归阶乘、正则回溯），它就不会主动让出控制权，事件循环彻底停摆，其他协程全部饿死。
常见错误现象：
- 调用
time.sleep(5)看似只是“等”，但它不释放 GIL，实际是阻塞；应改用await asyncio.sleep(5) - 用
requests.get()发 HTTP 请求，表面是 I/O，但底层同步 socket 操作 + JSON 解析可能含隐式 CPU 耗时，尤其响应体大时 - 在
async def函数里调用numpy.linalg.svd()这类底层 C 实现的函数，若未显式释放 GIL，仍会锁住事件循环
asyncio.to_thread() 是最简方案（Python 3.9+）
这是官方推荐的轻量级解法，自动使用 concurrent.futures.ThreadPoolExecutor，封装了线程创建、提交、结果获取全过程，无需手动管理 executor 生命周期。
立即学习“Python免费学习笔记（深入）”；
使用场景：
- 单次、中低强度 CPU 任务（如小数据量 base64 编码、简单图像缩放、JSON schema 校验）
- 调用无法异步化的第三方库（如旧版
pdfminer、lxml解析） - 不想引入额外依赖，且 Python 版本 ≥ 3.9
示例：
import asyncio import math <p>def cpu_intensive(n):</p><h1>模拟 CPU 工作：计算大数阶乘</h1><pre class="brush:php;toolbar:false;">return math.factorial(n)
async def main():
✅ 正确：委托给线程池
result = await asyncio.to_thread(cpu_intensive, 10000)
print("done:", len(str(result)))asyncio.run(main())
⚠️ 注意：asyncio.to_thread() 底层仍是线程池，不是进程池；它不能绕过 GIL 实现真正的并行计算，只解决“不让事件循环卡死”这一个问题。
何时必须换 ProcessPoolExecutor
当任务真正吃满 CPU、需要多核并行（比如批量图像滤镜、蒙特卡洛模拟、矩阵乘法），线程池毫无意义——GIL 会让所有线程排队等一个核。这时得上进程池。
关键实操点：
- 必须用
concurrent.futures.ProcessPoolExecutor，不能用multiprocessing.Pool：后者对象不可序列化，传入run_in_executor会报PicklingError -
run_in_executor第一个参数要传 executor 实例，不能为None（那是默认线程池） - 进程间无共享内存，所有参数和返回值必须可 pickle；避免传 lambda、嵌套函数、带绑定方法的对象
- 进程启动开销大，适合“单次重任务”或“批量聚合任务”，别拿它跑几千个微小计算
示例：
import asyncio
from concurrent.futures import ProcessPoolExecutor
import numpy as np
<p>def cpu_heavy(arr):
return np.linalg.svd(arr)[1].sum()</p><p>async def main():
loop = asyncio.get_running<em>loop()
data = [np.random.rand(1000, 1000) for </em> in range(3)]</p><pre class="brush:php;toolbar:false;">with ProcessPoolExecutor() as pool:
# ✅ 正确：显式传入 pool 实例
results = await asyncio.gather(*[
loop.run_in_executor(pool, cpu_heavy, arr)
for arr in data
])
print(results)asyncio.run(main())
真正容易被忽略的是任务粒度和资源边界：线程池适合“快进快出”的阻塞调用，进程池适合“重而少”的计算单元；混用时别让 executor 实例泄漏（务必用 with），也别在协程外提前初始化 pool 后传入——跨协程复用 executor 可以，但跨进程不行。
