def METHOD_NAME(self):
    # type: () -> None
    while True:
        callback = self._queue.get()
        try:
            if callback is _TERMINATOR:
                break
            try:
                callback()
            except Exception:
                logger.error("Failed processing job", exc_info=True)
        finally:
            self._queue.task_done()
        sleep(0)