@@ -51,10 +51,9 @@ def __init__(self, widget_id: Tab, main_config: BabbleConfig, osc_queue: Queue):
51
51
# Set the event until start is called, otherwise we can block if shutdown is called.
52
52
self .cancellation_event .set ()
53
53
self .capture_event = Event ()
54
- self .capture_queue = Queue (maxsize = 1 )
55
- self .roi_queue = Queue (maxsize = 1 )
56
-
57
- self .image_queue = Queue (maxsize = 1 )
54
+ self .capture_queue = Queue (maxsize = 2 )
55
+ self .roi_queue = Queue (maxsize = 2 )
56
+ self .image_queue = Queue (maxsize = 500 )
58
57
59
58
self .ransac = BabbleProcessor (
60
59
self .config ,
@@ -67,7 +66,7 @@ def __init__(self, widget_id: Tab, main_config: BabbleConfig, osc_queue: Queue):
67
66
self .cam_id ,
68
67
)
69
68
70
- self .camera_status_queue = Queue (maxsize = 1 )
69
+ self .camera_status_queue = Queue (maxsize = 2 )
71
70
self .camera = Camera (
72
71
self .config ,
73
72
0 ,
@@ -211,6 +210,11 @@ def stop(self):
211
210
self .camera_thread .join ()
212
211
213
212
def render (self , window , event , values ):
213
+ if self .image_queue .qsize () > 2 :
214
+ with self .image_queue .mutex :
215
+ self .image_queue .queue .clear ()
216
+ else :
217
+ pass
214
218
changed = False
215
219
# If anything has changed in our configuration settings, change/update those.
216
220
if (
0 commit comments