python - 像gevent中的cron(计时器)

Question

如何在 gevent 中制作经典计时器？

我目前正在使用 gevent.spawn_later 但有没有办法像 cron 一样使用 core.timer 就像说“按间隔执行回调”？

def callback():
    # do something
    print '!'

timer = core.timer(10, callback)
timer.start()

outpout:
0s
10s  !
20s  !
30s  !

Answer 1

这取决于您希望工作安排的准确程度。有几种机制:

This blog有一个使用 gevent.spawn_later 创建计时器的巧妙技巧:

def schedule(delay, func, *args, **kw_args):
    gevent.spawn_later(0, func, *args, **kw_args)
    gevent.spawn_later(delay, schedule, delay, func, *args, **kw_args)

或者当然你可以简单地睡在一个可能更具可读性的循环中:

def run_regularly(self, function, interval, *args, **kwargs):
    while True:
        gevent.sleep(interval)
        function(*args, **kwargs)

然而，这两者都会随着时间的推移而漂移，特别是如果您的函数相对于间隔需要时间来完成。您可以通过在函数执行时调整 sleep 间隔来进行补偿:

def run_regularly(self, function, interval, *args, **kwargs):
    while True:
        before = time.time()
        function(*args, **kwargs)

        duration = time.time() - before
        if duration < interval:
            gevent.sleep(interval-duration)
        else:
            warning("function %s duration exceeded %f interval (took %f)" % (
                function.__name__, interval, duration))

这仍然会漂移，只是没有那么多...