Python中如何避免asyncio事件循环被同步代码阻塞？-Python教程-PHP中文网

同步代码会直接卡住整个asyncio事件循环，因其阻塞调用不主动让出控制权，导致其他协程无法调度；必须通过run_in_executor或专用异步库移出主线程。

python中如何避免asyncio事件循环被同步代码阻塞？

同步代码会直接卡住整个 asyncio 事件循环，没有“避免”的余地——只有把阻塞操作移出事件循环主线程。

为什么 time.sleep() 或 requests.get() 会让 async 代码变慢？

asyncio 的事件循环运行在单线程中，它靠协作式调度（cooperative scheduling）切换协程。一旦遇到 time.sleep()、requests.get()、json.loads()（超大字符串）、subprocess.run() 等同步阻塞调用，CPU 控制权就交不出去，其他协程全部挂起，哪怕它们本可以并发处理 I/O。

常见现象：asyncio.sleep(0) 不生效、多个 await asyncio.create_task(...) 实际串行执行、HTTP 请求响应时间翻倍甚至超时。

Python 的 GIL 不是主因，关键是“不 yield 控制权”
asyncio 本身不拦截系统调用，os.read() 这类底层阻塞也会卡死循环
第三方库若没提供 async 接口（如旧版 psycopg2），直接 await 也没用

用 asyncio.to_thread() 拆离 CPU/IO 密集型同步调用

Python 3.9+ 提供了轻量方案：把同步函数扔进线程池执行，主线程继续跑事件循环。这是目前最常用、开销可控的解法。

适用场景：time.sleep() 替代、requests.get()、cv2.imread()、pandas.read_csv()、lxml.etree.fromstring() 等。

import asyncio
import requests
<p>async def fetch_sync():</p><h1>❌ 错误：直接调用会阻塞</h1><pre class="brush:php;toolbar:false;"># return requests.get("https://httpbin.org/delay/2").json()

# ✅ 正确：丢进线程池
loop = asyncio.get_running_loop()
result = await loop.run_in_executor(None, requests.get, "https://httpbin.org/delay/2")
return result.json()

Python Use Agent

智能执行Python任务，自动生成、执行代码并反馈结果，无需额外配置，兼容旧命令。

下载

None 表示使用默认线程池（concurrent.futures.ThreadPoolExecutor），一般够用
若需控制线程数或复用，可提前创建 executor 并传入
注意：不能用于需要主线程上下文的对象（如某些 GUI 库、TLS 上下文绑定的连接）

用 asyncio.to_process() 处理真正危险的 CPU 绑定任务

当同步代码是纯计算（如加密哈希、科学计算、正则爆炸回溯），线程池仍受 GIL 限制，无法并行提速，还可能拖慢 I/O 协程。此时应换进程。

Python 3.12+ 引入 asyncio.to_process()；3.12 之前需手动封装 ProcessPoolExecutor：

from concurrent.futures import ProcessPoolExecutor
import hashlib
<p>def cpu_bound_work(data):
return hashlib.sha256(data.encode()).hexdigest()</p><p>async def hash_async(data):
loop = asyncio.get_running_loop()
with ProcessPoolExecutor() as pool:
return await loop.run_in_executor(pool, cpu_bound_work, data)
</p>