code: def stop_listening(self):
          
          self._halt_threads = True
          # wake them up so that they can die
          for name, queue_waker in self.recieved_signals.items():
              q, wake_event = queue_waker
              wake_event.set()
docs: Stop listener threads for acquistion queues