如何实现点击启动定时API轮询，对比offer自动更新context状态且不阻塞页面？

之前用threading实现时页面一直加载，本质是启动的后台线程没有和Web请求上下文完全解耦。大多数Python Web框架（Flask、Django等）会跟踪和当前请求绑定的所有活跃线程，只有等关联线程全部执行完成后才会返回HTTP响应，自然会让浏览器一直处于加载等待状态，无法实现后台静默运行的效果。
另外直接在请求生命周期的context里存任务状态也有问题：一旦请求返回，对应的请求级上下文就会被框架销毁，后台线程后续根本没法往这个已经被回收的对象里更新状态。

可落地方案 #

1. 前端轮询+独立后台调度（最轻量，无额外复杂依赖） #

这套方案从根源上绕开了框架等待关联线程的问题，适合中小规模场景：

• 用户点击启动按钮时，前端发送POST请求给服务端：
  • 服务端为该任务生成唯一task_id，把任务初始状态"未找到offer，仍在搜索中"、上一次API返回的offer列表快照、用户设置的轮询间隔x，全部存在公共可访问的缓存里（单实例可以用应用级内存字典，多实例用Redis）
  • 立刻返回带task_id的响应给前端，绝对不要在这个请求流程内启动绑定当前上下文的轮询线程
• 独立的后台轮询逻辑，在Web应用启动初始化时就挂载，完全脱离请求生命周期：
  • 用APScheduler这类通用调度器，注册按固定间隔执行的遍历任务：挨个检查缓存里未完成的offer搜索任务，到时间就发起目标API请求
  • 每次拿到API响应后，和缓存里存的上一次offer列表快照做一致性校验：
    • 响应无变化：更新缓存中该任务的状态为"未找到offer，仍在搜索中"
    • 响应有变化：更新缓存中该任务的状态为"已找到offer"，同时标记任务为已完成，后续不再触发轮询
• 前端拿到返回的task_id后，开启本地定时器，每1-2秒发送一次GET请求携带task_id拉取最新任务状态，拿到值后直接更新页面显示，全程不需要用户手动刷新。

注意：调度器一定要在应用启动钩子中初始化，不能和单个用户的请求绑定，从机制上避免框架挂起等待线程的问题。

2. 最小改动修复原有threading逻辑 #

如果已经写了threading相关的代码，不需要全部重写，只需要做两处调整就能解决卡加载的问题：

• 启动线程时，把线程运行需要的所有参数（轮询间隔、任务初始快照、任务ID）提前提取成独立变量，不要让线程内部引用当前请求的上下文对象，避免框架把线程和当前请求绑定
• 给线程设置守护属性，让其完全独立于请求栈运行，请求处理完成后立刻返回响应，不等待线程执行结束。

Flask场景的参考代码片段：

def run_polling_task(interval, initial_snapshot, task_id):
    # 内部逻辑完全独立，不引用request、g等请求级对象
    while 任务未完成:
        time.sleep(interval)
        current_offers = call_target_api()
        if current_offers != initial_snapshot:
            cache.set(task_id, {"status": "已找到offer"})
            break
        cache.set(task_id, {"status": "未找到offer，仍在搜索中"})

# 视图函数内启动任务
def start_task():
    # 提前把所有需要的参数读出来
    x_interval = request.args.get("interval", 10)
    initial_snapshot = call_target_api()
    task_id = generate_unique_id()
    cache.set(task_id, {"status": "未找到offer，仍在搜索中"})

    # 启动独立线程，不绑定当前请求
    poll_thread = threading.Thread(
        target=run_polling_task,
        args=(x_interval, initial_snapshot, task_id),
        daemon=True
    )
    poll_thread.start()

    # 立刻返回，不等线程跑完
    return {"task_id": task_id}

常见踩坑提醒 #

• 不要把任务状态存在请求级的context对象里：请求返回后这类上下文就会被框架销毁，后台线程写入状态时会触发对象不存在的错误，所有状态读写都要走公共缓存
• 多实例部署时不要用应用内存存任务状态，换用Redis这类分布式缓存，否则不同实例的请求会读不到对应线程写入的状态
• 校验offer列表一致性时，先对列表按照offer的唯一标识做排序再比对，避免因为API返回的字段顺序变化、无关字段的默认值变动，误判成有新offer

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