本文介绍如何在保持发送顺序的前提下,将原本同步阻塞的 api 调用(如 send_to_space())改造为非阻塞异步执行,从而显著提升循环吞吐量,适用于 python 3.9+ 环境。
在实际开发中,我们常遇到这样一类场景:需按序向远程服务(如某协作空间 API)逐条提交数据,但每次调用都因网络延迟而耗时数十毫秒,且函数本身不可修改(同步阻塞、含 await 或 requests 等 I/O 操作)。若直接使用普通 for 循环,整个流程将线性阻塞——第 n+1 条消息必须等待第 n 条响应返回后才开始发送,导致整体耗时随列表长度线性增长。
此时,asyncio 是最恰当的选择——它不依赖多线程(避免 GIL 限制与线程安全问题),也不需要修改 send_to_space() 的内部实现,仅通过协程调度即可实现“逻辑上顺序发送、物理上无等待重叠”。关键在于:我们不 await 整个任务完成,而是立即 await 一个已启动的 asyncio.create_task(),使其在事件循环中“即刻出发”,同时确保前序任务已调度完毕后再调度下一个。这既维持了发送顺序(无并发竞争),又消除了空等时间。
以下是推荐的重构方案: