From ec97c1fc20ed5eae153f169f55233304313b5f02 Mon Sep 17 00:00:00 2001
From: zqc <835569504@qq.com>
Date: Tue, 3 Feb 2026 13:49:12 +0800
Subject: [PATCH] =?UTF-8?q?=E5=87=8F=E5=B0=91=E9=98=9F=E5=88=97=E4=B8=AD?=
 =?UTF-8?q?=E5=B8=A7=E7=9A=84=E6=95=B0=E9=87=8F=EF=BC=8C=E9=99=8D=E4=BD=8E?=
 =?UTF-8?q?=E5=BB=B6=E8=BF=9F?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 biz/checkpoint/checkpoint_biz.py | 5 +++--
 rtsp_service_ws_kadian.py        | 2 +-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/biz/checkpoint/checkpoint_biz.py b/biz/checkpoint/checkpoint_biz.py
index f215d71..4e9bf68 100644
--- a/biz/checkpoint/checkpoint_biz.py
+++ b/biz/checkpoint/checkpoint_biz.py
@@ -725,7 +725,7 @@ class FrameProcessorWorker(threading.Thread):
 
                 # 抽帧控制
                 if ts - self.last_ts.get(cam_id, 0) < target_interval:
-                    self.raw_queue.task_done()
+                    # self.raw_queue.task_done()
                     continue
                 self.last_ts[cam_id] = ts
 
@@ -793,9 +793,10 @@ class FrameProcessorWorker(threading.Thread):
                     # logger.info(f"[PERF] Camera {cam_id} - Total: {total_time:.1f}ms | "
                     #            f"Detect: {detect_time:.1f}ms | "
                     #            f"Encode: {encode_time:.1f}ms | ")
-                self.raw_queue.task_done()
 
             except Exception as e:
                 logger.error(f"[ERROR] Frame processing failed for camera {cam_id if 'cam_id' in locals() else 'unknown'}: {e}")
                 logger.exception("Exception details:")  # 打印完整的堆栈跟踪
                 # 继续处理下一帧，不要退出循环
+            finally:
+                self.raw_queue.task_done()
diff --git a/rtsp_service_ws_kadian.py b/rtsp_service_ws_kadian.py
index f697343..8b439bb 100644
--- a/rtsp_service_ws_kadian.py
+++ b/rtsp_service_ws_kadian.py
@@ -188,7 +188,7 @@ class RTSPService:
                         for c in cfg.get("cameras", [])]
 
         self.stop_event = threading.Event()
-        self.raw_queue = queue.Queue(maxsize=500)
+        self.raw_queue = queue.Queue(maxsize=2)
         self.ws_queue = queue.Queue(maxsize=1000)
 
         self.capture_workers = []