Golang中定時(shí)器的陷阱詳解
前言
在業(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è)事件。對(duì)于失敗,我們應(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ù)。
- 如果有,我們?cè)O(shè)置的定時(shí)器失敗了,我們可能讀到不正確的超時(shí)事件。
- 如果沒有,我們?cè)O(shè)置的定時(shí)器成功了,我們?cè)谠O(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ù)場(chǎng)景簡單時(shí),沒有必要主動(dòng)清空通道。比如,處理流程是:設(shè)置1次定時(shí)器,處理一次定時(shí)器,中間無中斷,下次Reset前,通道必然是空的。
當(dāng)業(yè)務(wù)場(chǎng)景復(fù)雜時(shí),不確定通道是否為空,那就主動(dòng)清除。
if len(Timer.C) > 0{ <-Timer.C } Timer.Reset(time.Second)
測(cè)試代碼
package main import ( "fmt" "time" ) // 不同情況下,Timer.Reset()的返回值 func test1() { fmt.Println("第1個(gè)測(cè)試: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è)測(cè)試:超時(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è)測(cè)試: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)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,如果有疑問大家可以留言交流,謝謝大家對(duì)腳本之家的支持。
相關(guān)文章
數(shù)據(jù)競(jìng)爭和內(nèi)存重分配Golang slice并發(fā)不安全問題解決
這篇文章主要為大家介紹了數(shù)據(jù)競(jìng)爭和內(nèi)存重分配Golang slice并發(fā)不安全問題解決,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-10-10文字解說Golang Goroutine和線程的區(qū)別
goroutine 是 Go語言中的輕量級(jí)線程實(shí)現(xiàn),由 Go 運(yùn)行時(shí)(runtime)管理,使用每一個(gè) go 關(guān)鍵字將會(huì)額外開啟一個(gè)新的協(xié)程 goroutine,今天通過本文給大家介紹下Golang Goroutine和線程的區(qū)別,感興趣的朋友一起看看吧2022-03-03GoLang?channel關(guān)閉狀態(tài)相關(guān)操作詳解
Channel?和?goroutine?的結(jié)合是?Go?并發(fā)編程的大殺器。而?Channel?的實(shí)際應(yīng)用也經(jīng)常讓人眼前一亮,通過與?select,cancel,timer?等結(jié)合,它能實(shí)現(xiàn)各種各樣的功能。接下來,我們就要介紹GoLang?channel關(guān)閉狀態(tài)相關(guān)操作2022-10-10Golang 實(shí)現(xiàn)插入排序的方法示例(2種)
這篇文章主要介紹了Golang 實(shí)現(xiàn)插入排序的方法示例,文中通過示例代碼介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-02-02Go語言中三個(gè)輸入函數(shù)(scanf,scan,scanln)的區(qū)別解析
本文詳細(xì)介紹了Go語言中三個(gè)輸入函數(shù)Scanf、Scan和Scanln的區(qū)別,包括用法、功能和輸入終止條件等,本文給大家介紹的非常詳細(xì),感興趣的朋友跟隨小編一起看看吧2024-10-10