Refactor app.py and util.py to use a custom Queue implementation called LQueue instead of the existing Queue

This commit is contained in:
Sergey Krashevich 2023-07-02 02:55:34 +03:00
parent c62a427c5c
commit 4e2a529b0e
No known key found for this signature in database
GPG Key ID: 625171324E7D3856
2 changed files with 3 additions and 3 deletions

View File

@ -192,12 +192,12 @@ class FrigateApp:
# Queues for clip processing
self.event_queue: Queue = ff.Queue()
self.event_processed_queue: Queue = ff.Queue()
self.video_output_queue: Queue = ff.Queue(
self.video_output_queue: Queue = LQueue(
maxsize=len(self.config.cameras.keys()) * 2
)
# Queue for cameras to push tracked objects to
self.detected_frames_queue: Queue = ff.Queue(
self.detected_frames_queue: Queue = LQueue(
maxsize=len(self.config.cameras.keys()) * 2
)

View File

@ -16,7 +16,7 @@ from collections import Counter
from collections.abc import Mapping
from multiprocessing import shared_memory
from typing import Any, AnyStr, Optional, Tuple
from faster_fifo import Queue as FFQueue, DEFAULT_CIRCULAR_BUFFER_SIZE, DEFAULT_TIMEOUT
from faster_fifo import Queue as FFQueue, DEFAULT_CIRCULAR_BUFFER_SIZE, DEFAULT_TIMEOUT
from queue import Full, Empty
import time
import cv2