快捷導(dǎo)航

淺析go中Ticker,Timer和Tick的用法與區(qū)別

更新時間：2023年10月22日 08:04:22 作者：nil

在go面試的時候,面試官經(jīng)常會問time包的Ticker,Timer以及Tick的區(qū)別,一般在超時控制的時候用的比較多,今天就跟隨小編一起來詳細學(xué)一下這幾個的區(qū)別吧

寫在前面

在go面試的時候，面試官經(jīng)常會問time包的Ticker,Timer以及Tick的區(qū)別，一般在超時控制的時候用的比較多。今天就來詳細學(xué)一下這幾個的區(qū)別

Ticker

Ticker是周期性定時器，即周期性的觸發(fā)一個事件，它會以一個間隔(interval)往channel發(fā)送一個事件(當(dāng)前時間)，而channel的接收者可以以固定的時間間隔從channel中讀取事件。通過Ticker本身提供的管道將事件傳遞出去

示例

func main() {
    t1 := time.NewTicker(3 * time.Second)
    defer t1.Stop()
    for {
       select {
       case <-t1.C:
          fmt.Printf("%s\n", time.Now())
       }
    }
}

結(jié)果

2023-10-21 18:53:30.629901 +0800 CST m=+3.001061072
2023-10-21 18:53:33.629444 +0800 CST m=+6.000526969
2023-10-21 18:53:36.629429 +0800 CST m=+9.000436237

通過NewTicker創(chuàng)建一個Ticker，然后通過通過for+select實現(xiàn)定時執(zhí)行。記住Ticker一定要調(diào)用Stop方法，關(guān)閉chan，否則容易造成內(nèi)存泄露。Ticker最常用的2個函數(shù)就是NewTicker和Stop。

Ticker主要用于定期循環(huán)執(zhí)行某一個操作。

Timer

用于執(zhí)行一次性任務(wù)。在指定時間間隔之后再下chan發(fā)送一個事件(當(dāng)前時間)

func main() {
    t1 := time.NewTimer(3 * time.Second)
    defer t1.Stop()
    for {
       t1.Reset(3 * time.Second)
       select {
       case <-t1.C:
          fmt.Printf("%s\n", time.Now())
       }
    }
}

用Timer也能實現(xiàn)Ticker循環(huán)執(zhí)行的功能，但是每次必須調(diào)用Reset方法，否則會死鎖，因為Timer只會執(zhí)行一次。不過Timer一般不用于循環(huán)執(zhí)行，它用于超時控制，比如調(diào)用某個rpc，如果超過3s則終止調(diào)用。

示例

func main() {
    t1 := time.NewTimer(3 * time.Second)
    defer t1.Stop()

    ctx, cancel := mockRPC()
    select {
    case <-ctx.Done():
       fmt.Printf("rpc end\n")
       break
    case <-t1.C:
       // t1時間到了，rpc還沒執(zhí)行完，則執(zhí)行cancel()并退出
       fmt.Printf("%s\n", time.Now())
       cancel()
    }
}

// mockRPC. 異步執(zhí)行5s鐘，如果已經(jīng)結(jié)束了則停止執(zhí)行
func mockRPC() (context.Context, context.CancelFunc) {
    ctx, cancel := context.WithCancel(context.Background())
    go func() {
       for i := 0; i < 5; i++ {
          select {
          case <-ctx.Done():
             break
          default:
             fmt.Printf("%d\n", i)
             time.Sleep(time.Second)
          }
       }
    }()

    return ctx, cancel
}

結(jié)果

0
1
2
2023-10-21 19:18:53.565153 +0800 CST m=+3.000558307

Tick

Tick其實最簡單，直接看它的源代碼

func Tick(d Duration) <-chan Time {
    if d <= 0 {
       return nil
    }
    return NewTicker(d).C
}

發(fā)現(xiàn)Tick其實就是一個Ticker的C，所以使用起來更方便

func main() {
    t1 := time.Tick(3 * time.Second)
    for {
       select {
       case <-t1:
          fmt.Printf("%s\n", time.Now())
       }
    }
}

但是有一個問題，由于Tick()函數(shù)沒有返回Ticker，我們無法關(guān)閉它，所以這個t1對應(yīng)的Ticker用于無法關(guān)閉，會造成內(nèi)存泄露。一般不推薦用Tick,直接使用Ticker就好了。應(yīng)該只能在程序結(jié)束的時候會回收內(nèi)存，但是Tick和Ticker區(qū)別這么小，不知道為什么要定義Tick()這個函數(shù)。