code: def _start_payloads(self):
          
          with self._lock:
              payloads = self._payloads.copy()
              self._payloads.clear()
          for subroutine in payloads:
              thread = CapturingThread(target=subroutine)
              thread.start()
              self._threads.add(thread)
              self._logger.debug('booted thread %s', thread)
          time.sleep(0)
docs: Start all queued payloads