def METHOD_NAME(self):
    self._log.debug("Starting scheduler %s", self._name)
    with self._cond:
        if self._running:
            raise AssertionError("Scheduler already running")
        self._running = True
        self._thread.METHOD_NAME()