code: def start_listening(self):
          
          self._qlisten()
          self._halt_threads = False
          for t in self.queue_threads:
              t.start()
docs: Start listener threads for acquistion callback queues