From 509e860c5c6908f721820b6b210ace2fcc9559f4 Mon Sep 17 00:00:00 2001
From: zhouyang <fjzhouyang@163.com>
Date: Thu, 13 Jul 2023 09:54:54 +0800
Subject: [PATCH] fix queue full
---
xznsh_flow/capture_queue.py | 9 +++++++--
1 file changed, 7 insertions(+), 2 deletions(-)
diff --git a/xznsh_flow/capture_queue.py b/xznsh_flow/capture_queue.py
index a3b452c..c0d979d 100644
--- a/xznsh_flow/capture_queue.py
+++ b/xznsh_flow/capture_queue.py
@@ -1,6 +1,7 @@
+import time
import json
import cv2
-from queue import Queue
+from queue import Queue, Full
from threading import Thread
from log import logger
@@ -57,7 +58,11 @@ def camera_add_queue(camera_name, camera_source, camera_queue):
result, frame_picture = capture_obj.read()
if not result:
continue
- camera_queue.put_nowait(frame_picture)
+ try:
+ camera_queue.put_nowait(frame_picture)
+ except Full:
+ time.sleep(0.01)
+ continue
def camera_mul_thread():