直接启动线程计时器

Question

我想在启动计时器后直接触发self._runSequence()函数。这是我的代码：

self.sequenceTimer = RepeatedTimer( sequenceDuration, self.__runSequence, sequence)

如果sequenceDuration等于10，则函数将在10秒后调用(据我所知，这是一个正常的计时器。(

这是RepeatedTimerClass:

from threading import Timer

class RepeatedTimer(object):
def __init__(self, interval, function, *args, **kwargs):
self._timer     = None
self.interval   = interval
self.function   = function
self.args       = args
self.kwargs     = kwargs
self.is_running = False
self.start()
def _run(self):
self.is_running = False
self.start()
self.function(*self.args, **self.kwargs)
def start(self):
if not self.is_running:
self._timer = Timer(self.interval, self._run)
self._timer.start()
self.is_running = True
def stop(self):
self._timer.cancel()
self.is_running = False

我已经尝试过的：

self.sequenceTimer = RepeatedTimer( sequenceDuration, self.__runSequence(sequence), sequence)

但当计时器触发__runSequence函数时，这给了我一个错误，告诉我我没有给__runSequence()函数提供参数。

Answer 1

如果我理解正确，您希望在初始化RepeatedTimer时执行function，然后定期执行，对吗？

不要在__init__中调用start，而是调用_run。它调用start并执行function。

import time
from threading import Timer

class RepeatedTimer(object):
def __init__(self, interval, function, *args, **kwargs):
self._timer     = None
self.interval   = interval
self.function   = function
self.args       = args
self.kwargs     = kwargs
self.is_running = False
self._run()
def _run(self):
self.is_running = False
self.start()
self.function(*self.args, **self.kwargs)
def start(self):
if not self.is_running:
self._timer = Timer(self.interval, self._run)
self._timer.start()
self.is_running = True
def stop(self):
self._timer.cancel()
self.is_running = False

print("Before initialization")
sequence_timer = RepeatedTimer(10, lambda *args, **kwargs: print(time.time(), *args, **kwargs), "foo", "bar", sep=" ; ")
print("After initialization")
time.sleep(50)
sequence_timer.stop()

输出

Before initialization
1622809236.0391436 ; foo ; bar
After initialization
1622809246.0429533 ; foo ; bar
1622809256.055273 ; foo ; bar
1622809266.0606596 ; foo ; bar
1622809276.0665863 ; foo ; bar

您可以看到，第一次执行发生在初始化完成之前。

---

您的第一次尝试已经正确。

self.sequenceTimer = RepeatedTimer(sequenceDuration, self.__runSequence, sequence)

第二个将传递self.__runSequence(sequence)(None，除非显式返回其他内容(的结果，而不是方法本身。