快捷導(dǎo)航

Golang中定時器的陷阱詳解

更新時間：2018年09月09日 16:24:54 作者：shitaibin

這篇文章主要給大家介紹了關(guān)于Golang中定時器陷阱的相關(guān)資料，文中通過示例代碼介紹的非常詳細，對大家學(xué)習(xí)或者使用golang具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧

前言

在業(yè)務(wù)中,我們經(jīng)常需要基于定時任務(wù)來觸發(fā)來實現(xiàn)各種功能。比如TTL會話管理、鎖、定時任務(wù)(鬧鐘)或更復(fù)雜的狀態(tài)切換等等。百納網(wǎng)主要給大家介紹了關(guān)于Golang定時器陷阱的相關(guān)內(nèi)容，所謂陷阱，就是它不是你認為的那樣，這種認知誤差可能讓你的軟件留下隱藏Bug。剛好Timer就有3個陷阱，我們會講

1）Reset的陷阱和

2）通道的陷阱，

3）Stop的陷阱與Reset的陷阱類似，自己探索吧。

下面話不多說了，來一起看看詳細的介紹吧

Reset的陷阱在哪

Timer.Reset()函數(shù)的返回值是bool類型，我們看一個問題三連：

它的返回值代表什么呢？
我們想要的成功是什么？
失敗是什么？

成功：一段時間之后定時器超時，收到超時事件。

失?。撼晒Φ姆疵?，我們收不到那個事件。對于失敗，我們應(yīng)當(dāng)做些什么，確保我們的定時器發(fā)揮作用。

Reset的返回值是不是這個意思？

通過查看文檔和實現(xiàn)，Timer.Reset()的返回值并不符合我們的預(yù)期，這就是誤差。它的返回值不代表重設(shè)定時器成功或失敗，而是在表達定時器在重設(shè)前的狀態(tài)：

當(dāng)Timer已經(jīng)停止或者超時，返回false。
當(dāng)定時器未超時時，返回true。

所以，當(dāng)Reset返回false時，我們并不能認為一段時間之后，超時不會到來，實際上可能會到來，定時器已經(jīng)生效了。

跳過陷阱，再遇陷阱

如何跳過前面的陷阱，讓Reset符合我們的預(yù)期功能呢？直接忽視Reset的返回值好了，它不能幫助你達到預(yù)期的效果。

真正的陷阱是Timer的通道，它和我們預(yù)期的成功、失敗密切相關(guān)。我們所期望的定時器設(shè)置失敗，通常只和通道有關(guān)：設(shè)置定時器前，定時器的通道Timer.C中是否已經(jīng)有數(shù)據(jù)。

如果有，我們設(shè)置的定時器失敗了，我們可能讀到不正確的超時事件。
如果沒有，我們設(shè)置的定時器成功了，我們在設(shè)定的時間得到超時事件。

接下來解釋為何失敗只與通道中是否存在超時事件有關(guān)。

定時器的緩存通道大小只為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
}

定時器創(chuàng)建后是單獨運行的，超時后會向通道寫入數(shù)據(jù)，你從通道中把數(shù)據(jù)讀走。當(dāng)前一次的超時數(shù)據(jù)沒有被讀取，而設(shè)置了新的定時器，然后去通道讀數(shù)據(jù)，結(jié)果讀到的是上次超時的超時事件，看似成功，實則失敗，完全掉入陷阱。

跨越陷阱，確保成功

如果確保Timer.Reset()成功，得到我們想要的結(jié)果？Timer.Reset()前清空通道。

當(dāng)業(yè)務(wù)場景簡單時，沒有必要主動清空通道。比如，處理流程是：設(shè)置1次定時器，處理一次定時器，中間無中斷，下次Reset前，通道必然是空的。

當(dāng)業(yè)務(wù)場景復(fù)雜時，不確定通道是否為空，那就主動清除。

if len(Timer.C) > 0{
 <-Timer.C
}
Timer.Reset(time.Second)

測試代碼

package main

import (
 "fmt"
 "time"
)

// 不同情況下，Timer.Reset()的返回值
func test1() {
 fmt.Println("第1個測試：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未超時，看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前通道中事件的數(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開始的時間: %v\n", sm2Start.Unix())
  fmt.Printf("通道中事件的時間：%v\n", t.Unix())
  if t.Sub(sm2Start) <= time.Second+time.Millisecond {
   fmt.Println("通道中的時間是重新設(shè)置sm2前的時間，即第一次超時的時間，所以第二次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ù)量:%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("通道中的時間是重新設(shè)置sm前的時間，即第一次超時的時間，所以第二次Reset失敗了")
 } else {
  fmt.Println("通道中的時間是重新設(shè)置sm后的時間，Reset成功了")
 }
}

func main() {
 test1()
 test2()
 test3()
}

總結(jié)

以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。

您可能感興趣的文章: