溫馨提示×
您好，登錄后才能下訂單哦！
點擊 登錄注冊 即表示同意《億速云用戶服務條款》
您好，登錄后才能下訂單哦！
前言
在業務中,我們經常需要基于定時任務來觸發來實現各種功能。比如TTL會話管理、鎖、定時任務(鬧鐘)或更復雜的狀態切換等等。百納網主要給大家介紹了關于Golang定時器陷阱的相關內容，所謂陷阱，就是它不是你認為的那樣，這種認知誤差可能讓你的軟件留下隱藏Bug。剛好Timer就有3個陷阱，我們會講
1）Reset的陷阱和
2）通道的陷阱，
3）Stop的陷阱與Reset的陷阱類似，自己探索吧。
下面話不多說了，來一起看看詳細的介紹吧
Reset的陷阱在哪
Timer.Reset()函數的返回值是bool類型，我們看一個問題三連：
成功：一段時間之后定時器超時，收到超時事件。
失敗：成功的反面，我們收不到那個事件。對于失敗，我們應當做些什么，確保我們的定時器發揮作用。
Reset的返回值是不是這個意思？
通過查看文檔和實現，Timer.Reset()的返回值并不符合我們的預期，這就是誤差。它的返回值不代表重設定時器成功或失敗，而是在表達定時器在重設前的狀態：
所以，當Reset返回false時，我們并不能認為一段時間之后，超時不會到來，實際上可能會到來，定時器已經生效了。
跳過陷阱，再遇陷阱
如何跳過前面的陷阱，讓Reset符合我們的預期功能呢？直接忽視Reset的返回值好了，它不能幫助你達到預期的效果。
真正的陷阱是Timer的通道，它和我們預期的成功、失敗密切相關。我們所期望的定時器設置失敗，通常只和通道有關：設置定時器前，定時器的通道Timer.C中是否已經有數據。
接下來解釋為何失敗只與通道中是否存在超時事件有關。
定時器的緩存通道大小只為1，無法多存放超時事件，看源碼。
// NewTimer creates a new Timer that will send
// the current time on its channel after at least duration d.
func NewTimer(d Duration) *Timer {
c := make(chan Time, 1) // 緩存通道大小為1
t := &Timer{
C: c,
r: runtimeTimer{
when: when(d),
f: sendTime,
arg: c,
},
}
startTimer(&t.r)
return t
}
定時器創建后是單獨運行的，超時后會向通道寫入數據，你從通道中把數據讀走。當前一次的超時數據沒有被讀取，而設置了新的定時器，然后去通道讀數據，結果讀到的是上次超時的超時事件，看似成功，實則失敗，完全掉入陷阱。
跨越陷阱，確保成功
如果確保Timer.Reset()成功，得到我們想要的結果？Timer.Reset()前清空通道。
當業務場景簡單時，沒有必要主動清空通道。比如，處理流程是：設置1次定時器，處理一次定時器，中間無中斷，下次Reset前，通道必然是空的。
當業務場景復雜時，不確定通道是否為空，那就主動清除。
if len(Timer.C) > 0{
<-Timer.C
}
Timer.Reset(time.Second)
測試代碼
package main
import (
"fmt"
"time"
)
// 不同情況下，Timer.Reset()的返回值
func test1() {
fmt.Println("第1個測試：Reset返回值和什么有關？")
tm := time.NewTimer(time.Second)
defer tm.Stop()
quit := make(chan bool)
// 退出事件
go func() {
time.Sleep(3 * time.Second)
quit <- true
}()
// Timer未超時，看Reset的返回值
if !tm.Reset(time.Second) {
fmt.Println("未超時，Reset返回false")
} else {
fmt.Println("未超時，Reset返回true")
}
// 停止timer
tm.Stop()
if !tm.Reset(time.Second) {
fmt.Println("停止Timer，Reset返回false")
} else {
fmt.Println("停止Timer，Reset返回true")
}
// Timer超時
for {
select {
case <-quit:
return
case <-tm.C:
if !tm.Reset(time.Second) {
fmt.Println("超時，Reset返回false")
} else {
fmt.Println("超時，Reset返回true")
}
}
}
}
func test2() {
fmt.Println("\n第2個測試:超時后，不讀通道中的事件，可以Reset成功嗎？")
sm2Start := time.Now()
tm2 := time.NewTimer(time.Second)
time.Sleep(2 * time.Second)
fmt.Printf("Reset前通道中事件的數量:%d\n", len(tm2.C))
if !tm2.Reset(time.Second) {
fmt.Println("不讀通道數據，Reset返回false")
} else {
fmt.Println("不讀通道數據，Reset返回true")
}
fmt.Printf("Reset后通道中事件的數量:%d\n", len(tm2.C))
select {
case t := <-tm2.C:
fmt.Printf("tm2開始的時間: %v\n", sm2Start.Unix())
fmt.Printf("通道中事件的時間：%v\n", t.Unix())
if t.Sub(sm2Start) <= time.Second+time.Millisecond {
fmt.Println("通道中的時間是重新設置sm2前的時間，即第一次超時的時間，所以第二次Reset失敗了")
}
}
fmt.Printf("讀通道后，其中事件的數量:%d\n", len(tm2.C))
tm2.Reset(time.Second)
fmt.Printf("再次Reset后，通道中事件的數量:%d\n", len(tm2.C))
time.Sleep(2 * time.Second)
fmt.Printf("超時后通道中事件的數量:%d\n", len(tm2.C))
}
func test3() {
fmt.Println("\n第3個測試：Reset前清空通道，盡可能通暢")
smStart := time.Now()
tm := time.NewTimer(time.Second)
time.Sleep(2 * time.Second)
if len(tm.C) > 0 {
<-tm.C
}
tm.Reset(time.Second)
// 超時
t := <-tm.C
fmt.Printf("tm開始的時間: %v\n", smStart.Unix())
fmt.Printf("通道中事件的時間：%v\n", t.Unix())
if t.Sub(smStart) <= time.Second+time.Millisecond {
fmt.Println("通道中的時間是重新設置sm前的時間，即第一次超時的時間，所以第二次Reset失敗了")
} else {
fmt.Println("通道中的時間是重新設置sm后的時間，Reset成功了")
}
}
func main() {
test1()
test2()
test3()
}
總結
以上就是這篇文章的全部內容了，希望本文的內容對大家的學習或者工作具有一定的參考學習價值，如果有疑問大家可以留言交流，謝謝大家對億速云的支持。
免責聲明：本站發布的內容（圖片、視頻和文字）以原創、轉載和分享為主，文章觀點不代表本網站立場，如果涉及侵權請聯系站長郵箱：is@yisu.com進行舉報，并提供相關證據，一經查實，將立刻刪除涉嫌侵權內容。
