直接启动线程定时器

Question

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

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

如果 sequenceDuration 等于 10 func 将在 10 秒后调用（作为我知道的普通计时器..）

这是RepeatedTimer Class:

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

如果我没理解错的话，你希望function在RepeatedTimer初始化时执行，然后定期执行，对吗？

不要在 __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 除非你明确地 return 其他东西）而不是方法本身。

直接启动线程定时器

Start a Thread Timer directly

python

timer