2

使用 Timer 类并在可调用对象中重新启动计时器,是在 python 的后台运行周期性计时器的标准方法。

这有两个主要缺点:

  • 它不是真正的周期性:计时器的设置,...
  • 它为每个时期创建一个新线程

Timer 类有替代品吗?看过sched类,但是在MainThread中运行会阻塞,不建议在多线程环境下运行。

如何在 python 中使用高频周期性计时器(100 ms 周期),例如在收集批量数据发送到数据库时定期清空文档队列?

4

1 回答 1

4

我想出了以下替代方案:

import threading
import time

class PeriodicThread(StoppableThread):
    '''Similar to a Timer(), but uses only one thread, stops cleanly and exits when the main thread exits'''

    def __init__ (self, period, callable, *args, **kwargs):
        super(PeriodicThread, self).__init__()
        self.period   = period
        self.args     = args
        self.callable = callable
        self.kwargs   = kwargs
        self.daemon   = True

    def run(self):
        while not self.stopped():
            self.callable(*self.args, **self.kwargs)
            time.sleep(self.period)
于 2013-01-24T20:37:06.967 回答