摘要：更循環(huán)定時(shí)器這里有更的方法重點(diǎn)研究類，它繼承了，但是重寫了父類的方法。再看看類中的語句，直到才會(huì)退出循環(huán)，定時(shí)器才結(jié)束。我們知道定時(shí)器有一個(gè)方法可以提前取消操作。這樣便完成了一個(gè)還不錯(cuò)的循環(huán)定時(shí)器。

python 如何寫一個(gè)定時(shí)器，循環(huán)定時(shí)做某一操作呢？

from threading import Timer
def hello(): 
    print "hello, world" 
   
t = Timer(10.0, hello) 
t.start()

10秒后輸出：

hello, world

重點(diǎn)研究 t = Timer(10.0, hello) 這句代碼，python 提供了一個(gè)Timer 對(duì)象，它會(huì)在指定的時(shí)間后執(zhí)行某一操作；它的完整形式：

class threading.Timer(interval, function, args=[], kwargs={})

interval 是時(shí)間間隔，function 是可調(diào)用的對(duì)象，args 和 kwargs 會(huì)作為 function 的參數(shù)。

注意：這里只會(huì)執(zhí)行一次 function，而不會(huì)一直定時(shí)執(zhí)行，且 Timer 在執(zhí)行操作的時(shí)候會(huì)創(chuàng)建一個(gè)新的線程。

Timer 在 python2 和 python3 有點(diǎn)區(qū)別：

# python2.7
def Timer(*args, **kwargs):
    return _Timer(*args, **kwargs)
# python3.7
class Timer(Thread):
    pass

在 python3，Timer 是 Thread 的子類；在 python2，_Timer 是 Thread 的子類，而 Timer 只是 _Timer 類的工廠方法。

上面的代碼只會(huì)打印一次 hello, world 后退出，那么如何循環(huán)間隔打印呢？

一種方法是在 function 里繼續(xù)注冊(cè)一個(gè) Timer，這樣就可以在下一個(gè) interval 繼續(xù)執(zhí)行 function；

from threading import Timer
def hello(): 
    print "hello, world" 
    Timer(10.0, hello) .start()

t = Timer(10.0, hello) 
t.start()

每隔 10 秒輸出一個(gè) hello, world。

達(dá)到效果了，但是這里面好像有點(diǎn)問題。回到 Timer 本身，它是一個(gè) thread，每次循環(huán)間隔操作，系統(tǒng)都要?jiǎng)?chuàng)建一個(gè)線程，然后再回收，這對(duì)系統(tǒng)來說開銷很大。如果時(shí)間間隔 interval 很短，系統(tǒng)會(huì)一下子創(chuàng)建很多線程，這些線程很難快速回收，導(dǎo)致系統(tǒng)內(nèi)存和cpu資源被消耗掉。
所以不提倡在 function 里繼續(xù)注冊(cè)一個(gè) Timer。

這里有更 pythonic 的方法：

from threading import _Timer
def hello():
     print "hello, world"
class RepeatingTimer(_Timer): 
    def run(self):
        while not self.finished.is_set():
            self.function(*self.args, **self.kwargs)
            self.finished.wait(self.interval)
t = RepeatingTimer(10.0, hello)
t.start()

重點(diǎn)研究 RepeatingTimer 類，它繼承了 threading._Timer，但是重寫了父類的 run 方法。這是 Python2 的寫法，python3 中 RepeatingTimer 應(yīng)該繼承 threading.Timer。

為什么要重寫 Thread 的 run 方法？

_Timer 是一個(gè) Thread 子類，我們先看看 Thread 類的 run 用法。

from threading import Thread
def hello():
     print "hello, world"
# 繼承 Thread
class MyThread(Thread):
    # 把要執(zhí)行的代碼寫到run函數(shù)里面 線程在創(chuàng)建后會(huì)直接運(yùn)行run函數(shù)
    def run(self):
        hello()
t = MyThread()
t.start()

Thread 對(duì)象的完整定義：

class threading.Thread(group=None, target=None, name=None, args=(), kwargs={})

其中 run 方法代碼：

class Thread(_Verbose):
    def run(self):
        try:
            if self.__target:
                self.__target(*self.__args, **self.__kwargs)
        finally:
            # Avoid a refcycle if the thread is running a function with
            # an argument that has a member that points to the thread.
            del self.__target, self.__args, self.__kwargs

標(biāo)準(zhǔn)的 run 方法用于執(zhí)行用戶傳入構(gòu)造函數(shù)的 target 方法。 子類可以重寫 run 方法，把要執(zhí)行的代碼寫到 run 里面，線程在創(chuàng)建后，用戶調(diào)用 start() 方法會(huì)運(yùn)行 run() 方法。

所以 RepeatingTimer 重寫 _Timer 的 run() 方法，可以改變線程的執(zhí)行體，當(dāng)我們調(diào)用 RepeatingTimer 的 start() 方法時(shí)會(huì)執(zhí)行我們重寫的 run() 方法。

再看看 RepeatingTimer 類中的 while not self.finished.is_set() 語句，self.finished.is_set() 直到 True 才會(huì)退出循環(huán)，定時(shí)器才結(jié)束。finished 是 threading.Event 對(duì)象。一個(gè) Event 對(duì)象管理著一個(gè) flag 標(biāo)志，它能被 set() 方法設(shè)置為 True，也能被 clear() 方法設(shè)置為 False，調(diào)用 wait([timeout]) 線程會(huì)一直 sleep 到 flag 為 True 或超時(shí)時(shí)間到達(dá)。

我們知道定時(shí)器有一個(gè) cancel() 方法可以提前取消操作。它其實(shí)是調(diào)用 Event.clear() 方法提前讓 wait 方法結(jié)束等待，并且判斷在 flag 為 true 的情況下不執(zhí)行定時(shí)器操作。具體的代碼：

class _Timer(Thread):
    """Call a function after a specified number of seconds:
            t = Timer(30.0, f, args=[], kwargs={})
            t.start()
            t.cancel() # stop the timer"s action if it"s still waiting
    """

    def __init__(self, interval, function, args=[], kwargs={}):
        Thread.__init__(self)
        self.interval = interval
        self.function = function
        self.args = args
        self.kwargs = kwargs
        self.finished = Event()

    def cancel(self):
        """Stop the timer if it hasn"t finished yet"""
        self.finished.set()

    def run(self):
        self.finished.wait(self.interval)
        if not self.finished.is_set():
            self.function(*self.args, **self.kwargs)
        self.finished.set()

所以 RepeatingTimer 的 run 方法會(huì)一直執(zhí)行 while 循環(huán)體，在循環(huán)體了會(huì)執(zhí)行用戶傳入的 function 對(duì)象，并等待指定的時(shí)間。當(dāng)用戶想退出定時(shí)器時(shí)，只需要調(diào)用 cancel 方法，將 flag 置為 True 便不會(huì)繼續(xù)執(zhí)行循環(huán)體了。這樣便完成了一個(gè)還不錯(cuò)的循環(huán)定時(shí)器。