直接启动线程计时器

Question

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

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

如果sequenceDuration等于10，10秒后将调用func（我知道这是一个正常的计时器..）

这是RepeatedTimer{}：

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)

但是当计时器触发__runSequencefunc时，这会给我一个错误，告诉我没有给__runSequence()func提供参数

谢谢你的回复

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的结果，除非显式返回其他内容），而不是方法本身