docs: def run_queues(self):
          """Run all queues that have data queued"""
  
          if self.exception:
              # pylint: disable=raising-bad-type
              raise self.exception
          listeners = self.__listeners_for_thread
          return sum(l.process() for l in listeners) > 0