Gundy
9452351edb
fix(sse): 每个 SSE 连接独立订阅者队列, 修复多客户端告警丢失
此前行情/告警/五档/复盘四通道共用服务级 Event + pending 列表,
pop 是「取走」语义: 开多个标签页或设备时, 告警只会被先醒来的那条
连接消费, 其余连接永远收不到; 共享 Event 的 clear/wait 也存在互相
吞信号的竞态。
- 新增 QuoteSubscriber: 每连接独立 Event + 队列, 生产侧广播
- /api/intraday/stream 改为 subscribe → wait/pop → finally
unsubscribe, 单事件等待替代原先每轮 4 个 to_thread 任务
(被 cancel 的 to_thread 线程实际仍在跑, 多客户端会耗尽线程池)
- 背压上限不变 (告警 1000 / 复盘 200, 每订阅者独立)
2026-07-03 14:11:26 +08:00
..
2026-06-18 17:18:23 +08:00
2026-06-22 17:42:04 +08:00
2026-06-27 23:23:34 +08:00
2026-07-03 14:11:26 +08:00
2026-06-23 14:00:09 +08:00
2026-06-28 16:18:46 +08:00
2026-07-01 23:02:37 +08:00
2026-06-25 22:39:34 +08:00
2026-06-18 17:18:23 +08:00
2026-07-03 14:11:26 +08:00
2026-06-29 17:17:44 +08:00
2026-06-30 17:28:18 +08:00
2026-07-02 17:22:42 +08:00
2026-06-27 23:23:34 +08:00
2026-06-18 17:18:23 +08:00
2026-06-24 17:44:58 +08:00
2026-07-02 17:22:16 +08:00
2026-07-02 22:19:46 +08:00
2026-06-30 22:30:52 +08:00
2026-06-18 17:18:23 +08:00
2026-06-26 23:34:54 +08:00
2026-07-02 22:19:46 +08:00
2026-06-27 23:23:34 +08:00