为什么这个调度功能不能按预期工作？答案

【问题标题】：Why does this scheduling function not work as expected?为什么这个调度功能不能按预期工作？
【发布时间】：2016-01-10 05:41:52
【问题描述】：

我正在编写一个小应用程序来验证一些网络应用程序是否健康。为此，我编写了一个简单的HealthCheck 抽象类，它需要两个函数is_healthy 和on_fail。这是我注册两个健康检查的代码：

import threading
import sched
import time


def register_health_check(checker, interval):
    s = sched.scheduler(time.time, time.sleep)
    s.enter(interval, 1, _check, (s,checker,interval))
    t = threading.Thread(target=s.run, daemon=True)
    t.start()


def _check(sc, checker, interval):
    if checker.is_healthy():
        sc.enter(interval, 1, _check, (sc,checker,interval))
    else:
        checker.on_fail()

然后，为了注册健康检查，我这样做：

register_health_check(CheckMain('foo'), 1)
register_health_check(CheckMain('bar'), 5)

CheckMain 的is_healthy 分别只打印checking foo 或checking bar。我期望的输出是：

checking foo // 1 second
checking foo // 2 seconds
checking foo // 3 seconds
checking foo // 4 seconds
checking foo // 5 seconds
checking bar // also 5 seconds-ish
checking foo // 6 seconds
checking foo // etc.
...

实际输出为：

checking foo
checking foo
checking foo
checking foo
checking foo
checking foo
checking foo
checking foo
checking bar
checking foo
checking bar
checking foo
checking foo
checking foo
checking foo
checking foo
checking foo
checking foo
checking foo

我的实现有什么问题？

【问题讨论】：

标签： python multithreading scheduled-tasks

【解决方案1】：

由于没有人回答，我认为多线程对于这项任务来说太复杂了。我真正想做的就是在需要时执行一堆检查。我重新设计了模块，如下所示：

health_checks = []


def register_health_check(checker):
    health_checks.append(checker)


def _check_all(sc):
    for hc in health_checks:
        hc.time_passed += 1
        if hc.time_passed == hc.interval_secs:
            hc.reset()
            if not hc.is_healthy():
                hc.on_fail()
    sc.enter(1, 1, _check_all, (sc,))


def start():
    s = sched.scheduler(time.time, time.sleep)
    s.enter(1, 1, _check_all, (s,))
    s.run()

【讨论】：