queue.py 文件源码

def _overdueCheckLoop(self):
        """
        While the service is running, keep checking for any overdue items.
        """
        self._overdueCheckCall = None

        if not self.running:
            returnValue(None)

        try:
            yield self._overdueCheck()
        except Exception as e:
            log.error("_overdueCheckLoop: {exc}", exc=e)

        if not self.running:
            returnValue(None)

        self._overdueCheckCall = self.reactor.callLater(
            self.queueOverduePollInterval, self._overdueCheckLoop
        )