code: def _poll_queue(self):
          
          while not self._stop_event.is_set():
              reply = self.run_job()
              self.send(reply)
              if self.queue:
                  continue
              time.sleep(0.02)
docs: Poll the queue for work.