fix queue full

V0.1.0
zhouyang 2 years ago
parent cf7ab4bcda
commit 509e860c5c

@ -1,6 +1,7 @@
import time
import json import json
import cv2 import cv2
from queue import Queue from queue import Queue, Full
from threading import Thread from threading import Thread
from log import logger from log import logger
@ -57,7 +58,11 @@ def camera_add_queue(camera_name, camera_source, camera_queue):
result, frame_picture = capture_obj.read() result, frame_picture = capture_obj.read()
if not result: if not result:
continue continue
try:
camera_queue.put_nowait(frame_picture) camera_queue.put_nowait(frame_picture)
except Full:
time.sleep(0.01)
continue
def camera_mul_thread(): def camera_mul_thread():

Loading…
Cancel
Save