快捷導(dǎo)航

golang1.23版本之前 Timer Reset方法無(wú)法正確使用

更新時(shí)間：2025年01月27日 09:53:29 作者：思wu邪

在Go 1.23之前,使用`time.Reset`函數(shù)時(shí)需要先調(diào)用`Stop`并明確從timer的channel中抽取出東西,以避免潛在的問(wèn)題,然而,這在實(shí)際代碼中難以實(shí)現(xiàn),因?yàn)樵O(shè)置定時(shí)器狀態(tài)和發(fā)送channel的操作并不是原子的,在某些情況下,這會(huì)導(dǎo)致timer在不應(yīng)該觸發(fā)時(shí)提前觸發(fā)

golang1.23 之前 Reset ?到底有什么問(wèn)題

在 golang 的 time.Reset 文檔中有這么一句話，為了防止文檔更新而導(dǎo)致內(nèi)容變動(dòng)，這里粘貼出來(lái):

Before Go 1.23, the only safe way to use Reset was to [Stop] and explicitly drain the timer first. See the NewTimer documentation for more details. 在Go 1.23 之前，唯一安全使用Reset函數(shù)的方式是：在使用之前調(diào)用Stop函數(shù)并且明確的從timer的channel中抽取出東西。

雖然文檔中已經(jīng)告訴了正確使用的方式，但是實(shí)際上在真正的代碼中無(wú)法達(dá)到這個(gè)要求，參考下方代碼（來(lái)源代碼來(lái)源）：

//consumer
    go func() {
        // try to read from channel, block at most 5s.
        // if timeout, print time event and go on loop.
        // if read a message which is not the type we want(we want true, not false),
        // retry to read.
        timer := time.NewTimer(time.Second * 5)
        for {
            // timer may be not active, and fired
            if !timer.Stop() {
                select {
                case <-timer.C: //try to drain from the channel，嘗試抽取，由于使用select，因此這里可以保證：不阻塞 + 一定抽取成功
                default:
                }
            }
            timer.Reset(time.Second * 5)  //重置定時(shí)器
            select {
            case b := <-c:
                if b == false {
                    fmt.Println(time.Now(), ":recv false. continue")
                    continue
                }
                //we want true, not false
                fmt.Println(time.Now(), ":recv true. return")
                return
            case <-timer.C:
                fmt.Println(time.Now(), ":timer expired")
                continue
            }
        }
    }()

在上面的代碼中，我們按照文檔的要求，在 timer.Reset ?之前已經(jīng)調(diào)用了 Stop ?函數(shù)，且如果 Stop 成功（返回 true），還嘗試抽取 timer，看起來(lái)似乎沒(méi)問(wèn)題的代碼中仍然存在問(wèn)題。

問(wèn)題的關(guān)鍵在于：當(dāng) Ticket 觸發(fā)的時(shí)候，設(shè)置定時(shí)器狀態(tài)的操作和發(fā)送 channel 的操作并不是原子的，見(jiàn) runOneTimer 函數(shù)。

異常情況：嘗試抽取 channel 在發(fā)送 channel 之前，這樣會(huì)導(dǎo)致 Reset 之前并沒(méi)有真正的清空 timer，后一次的 timer.C 還沒(méi)到觸發(fā)時(shí)間就異常的觸發(fā)了！

golang1.23 之前到底應(yīng)該如何正確的使用 Reset?

實(shí)際上簡(jiǎn)潔點(diǎn)就這么寫(xiě)，每次一個(gè)新的局部變量 Timer? 結(jié)構(gòu)體沒(méi)壓力，非要復(fù)用使用 Reset 的可讀性太差了，對(duì)維護(hù)者不友好，而且習(xí)慣了不好的寫(xiě)法，哪天一不小心就寫(xiě)出問(wèn)題了~

go func() {
		for {
			func() {
				timer := time.NewTimer(time.Second * 2)
				defer timer.Stop()

				select {
				case b := <-c:
					if !b {
						fmt.Println(time.Now(), "work...")
					}
				case <-timer.C: // BBB: normal receive from channel timeout event
					fmt.Println(time.Now(), "timeout")
				}
			}()
		}
	}()

參考：

https://tonybai.com/2016/12/21/how-to-use-timer-reset-in-golang-correctly/

https://www.v2ex.com/t/794283

到此這篇關(guān)于golang1.23版本之前 Timer Reset方法無(wú)法正確使用的文章就介紹到這了,更多相關(guān)golang Timer Reset方法無(wú)法正確使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: