Golang 定時器的終止與重置實現

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

定時器是一種通過設置一項任務,在未來的某個時刻執行該任務的機制。

定時器的種類通常隻有兩種,一種是隻執行一次的延時模式,一種是每隔一段時間執行一次的間隔模式。

在現代編程語言中,定時器幾乎是標配。除瞭設置定時器外,還需要有提供定時器的方法。

比如在 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)
}

先來看看運行結果

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

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

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

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)
}

現在,思考一下,炸彈是什麼時候引爆的!

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

我們來看看運行結果吧:

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

是不是和你想的一樣?如果不是,沒關系,聽我細細道來。
因為time.sleep()是讓主協程睡大覺,而timer.C讀的那條管道的協程是獨立的。所以你讓主協程睡大覺並不會影響定時器的計時,就相當於一個定時炸彈要引爆瞭,你馬上把手表的時間往後調,但是定時炸彈上的數字時間不會因為手表上的時間往後調而往後調。

誒!這時你會說我不是重置瞭嗎?
但是定時器超時瞭,那麼重置就不起作用瞭,你想一想,定時炸彈都爆炸瞭,你去重置還有效嗎?
如果我們將定時器的時間調到3秒,就是這樣:

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

那麼輸出結果會怎樣?

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

設置定時器後2秒,主協程才執行到Reset(),所以炸彈是在設置定時器12秒後才爆炸的。
有趣的是,當我查看Reset()的源碼時,發現瞭這樣一段註釋:

// 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)

根據我的理解,大意是這樣的,如果計時器已經過期,並且t.C已經被讀完瞭,那麼可以直接使用Reset。而如果程序Reset之前未從t.C中讀取過值的話,就需要調用Stop來結束定時器,才能使用reset。

到此這篇關於Golang 定時器的終止與重置實現的文章就介紹到這瞭,更多相關Golang 定時器終止與重置內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet!

推薦閱讀: