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():