fix frame build up latency by adding max size to every queue

Author: RedHawk989

.idea/discord.xml

@@ -116,7 +116,7 @@ def __init__(self, widget_id: Tab, main_config: BabbleSettingsConfig, osc_queue:
 
         self.cancellation_event = Event() # Set the event until start is called, otherwise we can block if shutdown is called.
         self.cancellation_event.set()
-        self.image_queue = Queue()
+        self.image_queue = Queue(maxsize=1)
 
 
     def started(self):

BabbleApp/algo_settings_widget.py

@@ -95,7 +95,7 @@ def main():
     # Check to see if we have an ROI. If not, bring up ROI finder GUI.
 
     # Spawn worker threads
-    osc_queue: queue.Queue[tuple[bool, int, int]] = queue.Queue()
+    osc_queue: queue.Queue[tuple[bool, int, int]] = queue.Queue(maxsize=5)
     osc = VRChatOSC(cancellation_event, osc_queue, config)
     osc_thread = threading.Thread(target=osc.run)
     # start worker threads

BabbleApp/babbleapp.py

@@ -51,10 +51,10 @@ def __init__(self, widget_id: Tab, main_config: BabbleConfig, osc_queue: Queue):
         # Set the event until start is called, otherwise we can block if shutdown is called.
         self.cancellation_event.set()
         self.capture_event = Event()
-        self.capture_queue = Queue()
-        self.roi_queue = Queue()
+        self.capture_queue = Queue(maxsize=1)
+        self.roi_queue = Queue(maxsize=1)
 
-        self.image_queue = Queue()
+        self.image_queue = Queue(maxsize=1)
 
         self.ransac = BabbleProcessor(
             self.config,
@@ -67,7 +67,7 @@ def __init__(self, widget_id: Tab, main_config: BabbleConfig, osc_queue: Queue):
             self.cam_id,
         )
 
-        self.camera_status_queue = Queue()
+        self.camera_status_queue = Queue(maxsize=1)
         self.camera = Camera(
             self.config,
             0,

BabbleApp/camera_widget.py

@@ -155,7 +155,7 @@ def __init__(self, widget_id: Tab, main_config: BabbleSettingsConfig, osc_queue:
 
         self.cancellation_event = Event() # Set the event until start is called, otherwise we can block if shutdown is called.
         self.cancellation_event.set()
-        self.image_queue = Queue()
+        self.image_queue = Queue(maxsize=1)
 
 
     def started(self):