快捷導(dǎo)航

Golang 定時(shí)器的終止與重置實(shí)現(xiàn)

更新時(shí)間：2021年08月27日 10:02:55 作者：ReganYue

在實(shí)際開(kāi)發(fā)過(guò)程中,我們有時(shí)候需要編寫(xiě)一些定時(shí)任務(wù)。很多人都熟悉定時(shí)器的使用，那么定時(shí)器應(yīng)該如何終止與重置，下面我們就一起來(lái)了解一下

昨日有讀者對(duì)定時(shí)器的終止有疑問(wèn)，今天我們來(lái)聊一聊定時(shí)器的終止與重置吧！

定時(shí)器是一種通過(guò)設(shè)置一項(xiàng)任務(wù)，在未來(lái)的某個(gè)時(shí)刻執(zhí)行該任務(wù)的機(jī)制。

定時(shí)器的種類(lèi)通常只有兩種，一種是只執(zhí)行一次的延時(shí)模式，一種是每隔一段時(shí)間執(zhí)行一次的間隔模式。

在現(xiàn)代編程語(yǔ)言中，定時(shí)器幾乎是標(biāo)配。除了設(shè)置定時(shí)器外，還需要有提供定時(shí)器的方法。

比如在 JavaScript 中，提供了 setTimeout、setInterval、clearTimeout 和 clearInterval 四個(gè) API，相比較而言是比較簡(jiǎn)單的。Go 語(yǔ)言中定時(shí)器的 API 就比較完善，所有的 API 都在 time 包中。

先看下面一段代碼：

func main() {
    timer := time.NewTimer(3 * time.Second)
    fmt.Println(time.Now(),"炸彈將于3秒后引爆")


    timer.Stop()
    fmt.Println("定時(shí)炸彈已拆除，定時(shí)器失效")

    
    t := <-timer.C
    fmt.Println("炸彈引爆于",t)
}

先來(lái)看看運(yùn)行結(jié)果

2021-08-25 10:08:34.706412 +0800 CST m=+0.023017601 炸彈將于3秒后引爆
定時(shí)炸彈已拆除，定時(shí)器失效
fatal error: all goroutines are asleep - deadlock!

我們可以趁定時(shí)器時(shí)間未到而使用Stop來(lái)將定時(shí)器終止，如果定時(shí)器已被叫停，其時(shí)間管道永遠(yuǎn)讀不出數(shù)據(jù)了，如果強(qiáng)制讀取，就會(huì)出現(xiàn)死鎖。因?yàn)槭褂肧top就是停止往管道里面寫(xiě)數(shù)據(jù)了，或者可以這樣說(shuō)，就是管道里面的數(shù)據(jù)已經(jīng)讀完了，使用time.NewTimer(3 * time.Second)就是往管道里面寫(xiě)數(shù)據(jù)。

我們?cè)趤?lái)看一個(gè)有趣的例子。

func main()  {
    timer := time.NewTimer(1 * time.Second)
    fmt.Println(time.Now())

    time.Sleep(2 * time.Second)
    fmt.Println(time.Now())

    timer.Reset(10*time.Second)
    fmt.Println("炸彈引爆于",<-timer.C)
}

現(xiàn)在，思考一下，炸彈是什么時(shí)候引爆的！

想知道答案嗎？不要著急,不要著急，休息，休息一會(huì)兒，答案馬上揭曉

我們來(lái)看看運(yùn)行結(jié)果吧：

2021-08-25 10:15:16.8406335 +0800 CST m=+0.014999801
2021-08-25 10:15:18.906213 +0800 CST m=+2.080579301
炸彈引爆于 2021-08-25 10:15:17.8522233 +0800 CST m=+1.026589601

是不是和你想的一樣？如果不是，沒(méi)關(guān)系，聽(tīng)我細(xì)細(xì)道來(lái)。
因?yàn)閠ime.sleep()是讓主協(xié)程睡大覺(jué)，而timer.C讀的那條管道的協(xié)程是獨(dú)立的。所以你讓主協(xié)程睡大覺(jué)并不會(huì)影響定時(shí)器的計(jì)時(shí)，就相當(dāng)于一個(gè)定時(shí)炸彈要引爆了，你馬上把手表的時(shí)間往后調(diào)，但是定時(shí)炸彈上的數(shù)字時(shí)間不會(huì)因?yàn)槭直砩系臅r(shí)間往后調(diào)而往后調(diào)。

誒！這時(shí)你會(huì)說(shuō)我不是重置了嗎？
但是定時(shí)器超時(shí)了，那么重置就不起作用了，你想一想，定時(shí)炸彈都爆炸了，你去重置還有效嗎？
如果我們將定時(shí)器的時(shí)間調(diào)到3秒，就是這樣：

timer := time.NewTimer(3 * time.Second)

那么輸出結(jié)果會(huì)怎樣？

2021-08-25 10:26:21.1299417 +0800 CST m=+0.020983301
2021-08-25 10:26:23.2191128 +0800 CST m=+2.110154401
炸彈引爆于 2021-08-25 10:26:33.227692 +0800 CST m=+12.118733601

設(shè)置定時(shí)器后2秒，主協(xié)程才執(zhí)行到Reset()，所以炸彈是在設(shè)置定時(shí)器12秒后才爆炸的。
有趣的是，當(dāng)我查看Reset()的源碼時(shí)，發(fā)現(xiàn)了這樣一段注釋?zhuān)?br />

// Reset should be invoked only on stopped or expired timers with drained channels.
// If a program has already received a value from t.C, the timer is known
// to have expired and the channel drained, so t.Reset can be used directly.
// If a program has not yet received a value from t.C, however,
// the timer must be stopped and—if Stop reports that the timer expired
// before being stopped—the channel explicitly drained:
//
//  if !t.Stop() {
//      <-t.C
//  }
//  t.Reset(d)

根據(jù)我的理解，大意是這樣的，如果計(jì)時(shí)器已經(jīng)過(guò)期，并且t.C已經(jīng)被讀完了，那么可以直接使用Reset。而如果程序Reset之前未從t.C中讀取過(guò)值的話(huà)，就需要調(diào)用Stop來(lái)結(jié)束定時(shí)器，才能使用reset。

到此這篇關(guān)于Golang 定時(shí)器的終止與重置實(shí)現(xiàn)的文章就介紹到這了,更多相關(guān)Golang 定時(shí)器終止與重置內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: