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

昨日有讀者對定時器的終止有疑問，今天我們來聊一聊定時器的終止與重置吧！

定時器是一種通過設(shè)置一項任務(wù)，在未來的某個時刻執(zhí)行該任務(wù)的機制。

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

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

比如在 JavaScript 中，提供了 setTimeout、setInterval、clearTimeout 和 clearInterval 四個 API，相比較而言是比較簡單的。Go 語言中定時器的 API 就比較完善，所有的 API 都在 time 包中。

先看下面一段代碼：

func main() {
    timer := time.NewTimer(3 * time.Second)
    fmt.Println(time.Now(),"炸彈將于3秒后引爆")
​
​
    timer.Stop()
    fmt.Println("定時炸彈已拆除，定時器失效")
​
    
    t := -timer.C
    fmt.Println("炸彈引爆于",t)
}

先來看看運行結(jié)果

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

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

我們在來看一個有趣的例子。

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)在，思考一下，炸彈是什么時候引爆的！

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

我們來看看運行結(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

是不是和你想的一樣？如果不是，沒關(guān)系，聽我細細道來。
因為time.sleep()是讓主協(xié)程睡大覺，而timer.C讀的那條管道的協(xié)程是獨立的。所以你讓主協(xié)程睡大覺并不會影響定時器的計時，就相當于一個定時炸彈要引爆了，你馬上把手表的時間往后調(diào)，但是定時炸彈上的數(shù)字時間不會因為手表上的時間往后調(diào)而往后調(diào)。

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

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

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

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

// 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īng)過期，并且t.C已經(jīng)被讀完了，那么可以直接使用Reset。而如果程序Reset之前未從t.C中讀取過值的話，就需要調(diào)用Stop來結(jié)束定時器，才能使用reset。

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