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!
推薦閱讀:
- Golang定時器Timer與Ticker的使用詳解
- Go timer如何調度
- golang 定時任務方面time.Sleep和time.Tick的優劣對比分析
- Go的固定時長定時器和周期性時長定時器
- 淺談golang 中time.After釋放的問題