ensure the multiprocessing queues are emptied and closed

This commit is contained in:
Blake Blackshear 2023-02-03 18:37:25 -06:00
parent e4b9d6161d
commit 57b3a37fd7

View File

@ -438,3 +438,15 @@ class FrigateApp:
shm = self.detection_shms.pop()
shm.close()
shm.unlink()
for queue in [
self.event_queue,
self.event_processed_queue,
self.video_output_queue,
self.detected_frames_queue,
self.recordings_info_queue,
]:
while not queue.empty():
queue.get_nowait()
queue.close()
queue.join_thread()