docs: def _reset(self):
          """Initialization that must happen before the arbiter is (re)started"""
          self._arbiter = None
          self._workers = None
          self._working_queue = None
          self._must_stop = threading.Event()