前言
在業(yè)務(wù)中,我們經(jīng)常需要基于定時(shí)任務(wù)來觸發(fā)來實(shí)現(xiàn)各種功能。比如TTL會(huì)話管理、鎖、定時(shí)任務(wù)(鬧鐘)或更復(fù)雜的狀態(tài)切換等等。百納網(wǎng)主要給大家介紹了關(guān)于Golang定時(shí)器陷阱的相關(guān)內(nèi)容，所謂陷阱，就是它不是你認(rèn)為的那樣，這種認(rèn)知誤差可能讓你的軟件留下隱藏Bug。剛好Timer就有3個(gè)陷阱，我們會(huì)講
1）Reset的陷阱和
2）通道的陷阱，
3）Stop的陷阱與Reset的陷阱類似，自己探索吧。
下面話不多說了，來一起看看詳細(xì)的介紹吧
Reset的陷阱在哪
Timer.Reset()函數(shù)的返回值是bool類型，我們看一個(gè)問題三連：
- 它的返回值代表什么呢？
- 我們想要的成功是什么？
- 失敗是什么？
成功：一段時(shí)間之后定時(shí)器超時(shí)，收到超時(shí)事件。
失?。撼晒Φ姆疵?，我們收不到那個(gè)事件。對于失敗，我們應(yīng)當(dāng)做些什么，確保我們的定時(shí)器發(fā)揮作用。
Reset的返回值是不是這個(gè)意思？
通過查看文檔和實(shí)現(xiàn)，Timer.Reset()的返回值并不符合我們的預(yù)期，這就是誤差。它的返回值不代表重設(shè)定時(shí)器成功或失敗，而是在表達(dá)定時(shí)器在重設(shè)前的狀態(tài)：
- 當(dāng)Timer已經(jīng)停止或者超時(shí)，返回false。
- 當(dāng)定時(shí)器未超時(shí)時(shí)，返回true。
所以，當(dāng)Reset返回false時(shí)，我們并不能認(rèn)為一段時(shí)間之后，超時(shí)不會(huì)到來，實(shí)際上可能會(huì)到來，定時(shí)器已經(jīng)生效了。
跳過陷阱，再遇陷阱
如何跳過前面的陷阱，讓Reset符合我們的預(yù)期功能呢？直接忽視Reset的返回值好了，它不能幫助你達(dá)到預(yù)期的效果。
真正的陷阱是Timer的通道，它和我們預(yù)期的成功、失敗密切相關(guān)。我們所期望的定時(shí)器設(shè)置失敗，通常只和通道有關(guān)：設(shè)置定時(shí)器前，定時(shí)器的通道Timer.C中是否已經(jīng)有數(shù)據(jù)。
- 如果有，我們設(shè)置的定時(shí)器失敗了，我們可能讀到不正確的超時(shí)事件。
- 如果沒有，我們設(shè)置的定時(shí)器成功了，我們在設(shè)定的時(shí)間得到超時(shí)事件。
接下來解釋為何失敗只與通道中是否存在超時(shí)事件有關(guān)。
定時(shí)器的緩存通道大小只為1，無法多存放超時(shí)事件，看源碼。
// 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
}
定時(shí)器創(chuàng)建后是單獨(dú)運(yùn)行的，超時(shí)后會(huì)向通道寫入數(shù)據(jù)，你從通道中把數(shù)據(jù)讀走。當(dāng)前一次的超時(shí)數(shù)據(jù)沒有被讀取，而設(shè)置了新的定時(shí)器，然后去通道讀數(shù)據(jù)，結(jié)果讀到的是上次超時(shí)的超時(shí)事件，看似成功，實(shí)則失敗，完全掉入陷阱。
跨越陷阱，確保成功
如果確保Timer.Reset()成功，得到我們想要的結(jié)果？Timer.Reset()前清空通道。
當(dāng)業(yè)務(wù)場景簡單時(shí)，沒有必要主動(dòng)清空通道。比如，處理流程是：設(shè)置1次定時(shí)器，處理一次定時(shí)器，中間無中斷，下次Reset前，通道必然是空的。
當(dāng)業(yè)務(wù)場景復(fù)雜時(shí)，不確定通道是否為空，那就主動(dòng)清除。
if len(Timer.C) > 0{
-Timer.C
}
Timer.Reset(time.Second)
測試代碼
package main
import (
"fmt"
"time"
)
// 不同情況下，Timer.Reset()的返回值
func test1() {
fmt.Println("第1個(gè)測試：Reset返回值和什么有關(guān)？")
tm := time.NewTimer(time.Second)
defer tm.Stop()
quit := make(chan bool)
// 退出事件
go func() {
time.Sleep(3 * time.Second)
quit - true
}()
// Timer未超時(shí)，看Reset的返回值
if !tm.Reset(time.Second) {
fmt.Println("未超時(shí)，Reset返回false")
} else {
fmt.Println("未超時(shí)，Reset返回true")
}
// 停止timer
tm.Stop()
if !tm.Reset(time.Second) {
fmt.Println("停止Timer，Reset返回false")
} else {
fmt.Println("停止Timer，Reset返回true")
}
// Timer超時(shí)
for {
select {
case -quit:
return
case -tm.C:
if !tm.Reset(time.Second) {
fmt.Println("超時(shí)，Reset返回false")
} else {
fmt.Println("超時(shí)，Reset返回true")
}
}
}
}
func test2() {
fmt.Println("\n第2個(gè)測試:超時(shí)后，不讀通道中的事件，可以Reset成功嗎？")
sm2Start := time.Now()
tm2 := time.NewTimer(time.Second)
time.Sleep(2 * time.Second)
fmt.Printf("Reset前通道中事件的數(shù)量:%d\n", len(tm2.C))
if !tm2.Reset(time.Second) {
fmt.Println("不讀通道數(shù)據(jù)，Reset返回false")
} else {
fmt.Println("不讀通道數(shù)據(jù)，Reset返回true")
}
fmt.Printf("Reset后通道中事件的數(shù)量:%d\n", len(tm2.C))
select {
case t := -tm2.C:
fmt.Printf("tm2開始的時(shí)間: %v\n", sm2Start.Unix())
fmt.Printf("通道中事件的時(shí)間：%v\n", t.Unix())
if t.Sub(sm2Start) = time.Second+time.Millisecond {
fmt.Println("通道中的時(shí)間是重新設(shè)置sm2前的時(shí)間，即第一次超時(shí)的時(shí)間，所以第二次Reset失敗了")
}
}
fmt.Printf("讀通道后，其中事件的數(shù)量:%d\n", len(tm2.C))
tm2.Reset(time.Second)
fmt.Printf("再次Reset后，通道中事件的數(shù)量:%d\n", len(tm2.C))
time.Sleep(2 * time.Second)
fmt.Printf("超時(shí)后通道中事件的數(shù)量:%d\n", len(tm2.C))
}
func test3() {
fmt.Println("\n第3個(gè)測試：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)
// 超時(shí)
t := -tm.C
fmt.Printf("tm開始的時(shí)間: %v\n", smStart.Unix())
fmt.Printf("通道中事件的時(shí)間：%v\n", t.Unix())
if t.Sub(smStart) = time.Second+time.Millisecond {
fmt.Println("通道中的時(shí)間是重新設(shè)置sm前的時(shí)間，即第一次超時(shí)的時(shí)間，所以第二次Reset失敗了")
} else {
fmt.Println("通道中的時(shí)間是重新設(shè)置sm后的時(shí)間，Reset成功了")
}
}
func main() {
test1()
test2()
test3()
}
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。
您可能感興趣的文章:- Golang定時(shí)器的2種實(shí)現(xiàn)方法與區(qū)別
- golang定時(shí)器和超時(shí)的使用詳解
- Golang 定時(shí)器(Timer 和 Ticker),這篇文章就夠了
- 用golang實(shí)現(xiàn)一個(gè)定時(shí)器任務(wù)隊(duì)列實(shí)例
- golang中定時(shí)器cpu使用率高的現(xiàn)象詳析
- golang time包下定時(shí)器的實(shí)現(xiàn)方法
- Golang 定時(shí)器的終止與重置實(shí)現(xiàn)
