class_docstr: Class to manage reading from queues safely.
class_docstr_tok: ["Class","to","manage","reading","from","queues","safely","."]
code: def __init__(
      self,
      input_record_q: "Queue[Record]",
      result_q: "Queue[Result]",
      stopped: "Event",
      debounce_interval_ms: "float" = 1000,
  ) -> None:
      ExceptionThread.__init__(self, stopped=stopped)
      self._input_record_q = input_record_q
      self._result_q = result_q
      self._stopped = stopped
      self._debounce_interval_ms = debounce_interval_ms
  
imports: import logging
  import queue
  import sys
  import threading
  import time
  from typing import TYPE_CHECKING, Optional, Tuple, Type, Union
  from ..lib import tracelog
label_desc: Use image node_id 1 to create a new RecordLoopThread object from inherited base classes: ExceptionThread with example: obj = RecordLoopThread(input_record_q, result_q, stopped, debounce_interval_ms)