意外tornado.ioloop.PeriodicCallback行为

Question

为了弄清PeriodicCallback的日程安排，我编写了以下脚本：

import time
import tornado.ioloop

t0 = time.time()

def foo():
    time.sleep(1)
    print(time.time() - t0)

tornado.ioloop.PeriodicCallback(foo, 2000).start()
tornado.ioloop.IOLoop.instance().start()

我期望它每隔2秒或每3秒发射一次，这取决于龙卷风是否要等到完成后才能安排下一次活动。然而，我得到的是：

3.00190114975
6.00296115875
10.0029530525
14.0029621124
18.0029540062
22.0050959587
26.0040180683
30.005161047
34.0053040981

这里发生了什么事？

Answer 1

我认为您只是看到了运行IOLoop的开销造成的延迟。例如，如果我将PeriodicCallback更改为每5秒运行一次，则得到以下输出：

6.00595116615
12.0075321198
17.0060141087
22.0051832199
27.0067241192
32.0061450005
37.0066981316
42.0063281059
47.0067460537

这和你所期望的差不多。另外，为了回答您最初的问题，PeriodicCallback在完成睡眠后安排了下一次回调(这是直接从龙卷风源代码中获取的)：

class PeriodicCallback(object):
    def __init__(self, callback, callback_time, io_loop=None):
        self.callback = callback
        if callback_time <= 0:
            raise ValueError("Periodic callback must have a positive callback_time")
        self.callback_time = callback_time
        self.io_loop = io_loop or IOLoop.current()
        self._running = False
        self._timeout = None

    def start(self):
        """Starts the timer."""
        self._running = True
        self._next_timeout = self.io_loop.time()
        self._schedule_next()

    def _run(self):
        if not self._running:
            return
        try:
            self.callback() # Your function runs here.
        except Exception:
            app_log.error("Error in periodic callback", exc_info=True)
        self._schedule_next()  # Schedule next run after calling self.callback

    def _schedule_next(self):
        if self._running:
            current_time = self.io_loop.time()
            while self._next_timeout <= current_time:
                self._next_timeout += self.callback_time / 1000.0
            self._timeout = self.io_loop.add_timeout(self._next_timeout, self._run) # The callback is actually scheduled with the ioloop here.

Answer 2

在龙卷风应用程序中睡觉，即使是在“背景”PeriodicCallback中也不是一个好主意，因为它会阻塞IOLoop，并且会阻止它对事情进行适当的调度。如果使用的是“旋风”，则需要将所有长阻塞调用替换为非阻塞等价物(或将它们移动到其他线程)。用IOLoop.add_timeout代替睡眠，用IOStream或其他异步库替换网络操作，等等。