使用 Timer 类并在可调用对象中重新启动计时器,是在 python 的后台运行周期性计时器的标准方法。
这有两个主要缺点:
- 它不是真正的周期性:计时器的设置,...
- 它为每个时期创建一个新线程
Timer 类有替代品吗?看过sched类,但是在MainThread中运行会阻塞,不建议在多线程环境下运行。
如何在 python 中使用高频周期性计时器(100 ms 周期),例如在收集批量数据发送到数据库时定期清空文档队列?
我想出了以下替代方案:
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)