Python3.9+如何在循环中异步顺序调用同步API？

问题背景 #

现有如下Python代码：

def send_items(items_list):
    for item in items_list:
        sub_item = item['sub_item']
        send_to_space(sub_item)

if __name__ == "__main__":
    send_items(my_finite_list)

其中send_to_space()是同步阻塞的API调用函数，单次调用耗时数十毫秒，无需获取响应，但有以下约束：

• 请求必须按顺序发送
• 不能批量处理
• 无法修改send_to_space()函数本身
• 使用Python 3.9+版本

希望优化循环逻辑，让下一个请求能尽快发送，无需等待上一个请求的响应返回，请问应使用asyncio、threading还是其他方案？

最优方案：使用threading结合队列实现顺序非阻塞发送 #

为什么排除asyncio？ #

send_to_space()是同步阻塞函数，若要在asyncio中使用，必须通过loop.run_in_executor()将其委托给线程池执行，本质还是依赖线程，且需要额外处理协程的异步逻辑，徒增复杂度，完全没必要。

核心实现思路 #

采用单生产者-单消费者线程模型：

1. 主线程按顺序将所有sub_item放入线程安全的FIFO队列
2. 启动一个独立工作线程，从队列中按顺序取出任务并调用send_to_space()
3. 主线程完成任务提交后，等待队列清空、工作线程结束

该模型既严格保证请求发送顺序，又能让主线程快速完成任务提交，无需等待每个API调用阻塞完成。

代码实现 #

import threading
from queue import Queue

def send_items(items_list):
    # 创建线程安全队列，可设置最大容量避免内存溢出（可选）
    task_queue = Queue(maxsize=100)

    def worker_thread():
        # 工作线程：按顺序处理队列任务，收到None信号后退出
        while True:
            sub_item = task_queue.get()
            if sub_item is None:
                break
            send_to_space(sub_item)
            task_queue.task_done()

    # 启动后台工作线程
    threading.Thread(target=worker_thread, daemon=True).start()

    # 主线程按顺序提交所有任务
    for item in items_list:
        sub_item = item['sub_item']
        task_queue.put(sub_item)

    # 等待所有任务处理完成
    task_queue.join()
    # 发送退出信号，终止工作线程
    task_queue.put(None)

if __name__ == "__main__":
    send_items(my_finite_list)

方案优势 #

• 严格保证请求发送顺序：队列的FIFO特性确保任务执行顺序与提交顺序完全一致
• 低侵入性：无需修改原有send_to_space()函数，仅需对send_items()做逻辑改造
• 性能高效：主线程无需等待API调用阻塞，可快速完成所有任务提交
• 逻辑简洁：线程模型直观易懂，比asyncio协程方案更轻量化

补充说明 #

若需要更灵活的线程资源管理，也可使用concurrent.futures.ThreadPoolExecutor，但需注意必须按提交顺序等待结果才能保证执行顺序——而单线程队列方案已完全满足需求，且更轻量，无需额外线程池调度开销。

内容的提问来源于stack exchange，提问作者wsa225