快捷導(dǎo)航

Go?語言入門之Go?計時器介紹

更新時間：2022年05月04日 14:11:22 作者：宇宙之一粟

這篇文章主要介紹了Go?語言入門之Go?計時器，文章基于GO語言的相關(guān)資料展開對其中計時器的詳細內(nèi)容。具有一定的參考價值，需要的小伙伴可以參考一下

引言

一般來說，很多時候我們面臨這樣一種情況，即我們需要運行時間記錄器，它不斷向我們顯示當(dāng)前時間或在給定的時間間隔內(nèi)保持執(zhí)行一定的代碼和平，在這種情況下，我們應(yīng)該使用 ??Ticker???，使用這個我們需要使用 go 語言的 ??time??? 包，我們有一個名為 ??NewTicker()??? 的方法，它允許我們停止和啟動時間代碼，我們需要通過傳遞 ??chan??? 和 ??bool?? 作為將使用的參數(shù)來創(chuàng)建一個代碼通道檢查它是否打開，如果通道打開意味著計時器將繼續(xù)。

Go 的計時器

Go 提供了非常簡單的語法來實現(xiàn)一個計時器，定時器的結(jié)構(gòu)體定義：

type Ticker struct {
C <-chan Time // 拋出來的channel，給上層系統(tǒng)使用，實現(xiàn)計時
r runtimeTimer // 給系統(tǒng)管理使用的定時器，系統(tǒng)通過該字段確定定時器是否到時，如果到時，調(diào)用對應(yīng)的函數(shù)向C中推送當(dāng)前時間。
}

Ticker對外僅暴露一個 channel，指定的時間到來時就往該 channel 中寫入系統(tǒng)時間，也即一個事件。

Ticker 的使用方式也很簡單，代碼如下：

import time
TimeTicker := time.NewTicker(1 * time.Second)
TimeTicker.Stop()

??time??? : 如果想要使用??time?? 中的計時器，那么需要將其導(dǎo)入代碼中
??NewTicker()??? 函數(shù)：這個很好理解，新建一個計時器，然后該計時器以時間表達式作為參數(shù)，比如一秒??1*time.Second??? ，而不是直接傳入??1??? ，也可以傳入其他時間方式，比如??2*time.Millisecond??
最后，我們可以使用時間表達式調(diào)用由??NewTicker??? 函數(shù)創(chuàng)建的變量上的任何活動。例如，在上面的語法中，我們使用了??TimeTicker.Stop()??? 來停止時間計時器。我們可以在特定條件下使用它，比如定義倒數(shù) 10 秒的計時器，就可以檢查時間是否滿足 10 秒，一旦 10 秒發(fā)生，我們可以調(diào)用??TimeTicker.stop()??。

我們可以每隔一秒輸出一個結(jié)果，比如實現(xiàn)一個倒數(shù) 10 個數(shù)的功能：

package main
import (
"fmt"
"time"
)
func main() {
TimeTicker := time.NewTicker(1 * time.Second)
i := 10
for {
<-TimeTicker.C
fmt.Println("i = ", i)
i--
if i == 0 {
TimeTicker.Stop()
break
}
}
}

然后執(zhí)行該程序：

$ go run main.go
i = 10
i = 9
i = 8
i = 7
i = 6
i = 5
i = 4
i = 3
i = 2
i = 1

Ticker 計時器是如何工作的？

??NewTicker???創(chuàng)建的計時器與??NewTimer???創(chuàng)建的計時器持有的時間??channel???一樣都是帶一個緩存的??channel???，每次觸發(fā)后執(zhí)行的函數(shù)也是??sendTime???，這樣即保證了無論有誤接收方??Ticker??觸發(fā)時間事件時都不會阻塞：

func NewTicker(d Duration) *Ticker {
if d <= 0 {
panic(errors.New("non-positive interval for NewTicker"))
}
// Give the channel a 1-element time buffer.
// If the client falls behind while reading, we drop ticks
// on the floor until the client catches up.
c := make(chan Time, 1)
t := &Ticker{
C: c,
r: runtimeTimer{
when: when(d),
period: int64(d),
f: sendTime,
arg: c,
},
}
startTimer(&t.r)
return t
}

NewTicker()只是構(gòu)造了一個Ticker，然后把Ticker.r通過startTimer()交給系統(tǒng)協(xié)程維護。

其中period為事件觸發(fā)的周期。

其中??sendTime()??方法便是定時器觸發(fā)時的動作：

func sendTime(c interface{}, seq uintptr) {
select {
case c.(chan Time) <- Now():
default:
}
}

??sendTime?? 接收一個管道作為參數(shù)，其主要任務(wù)是向管道中寫入當(dāng)前時間。

停止Ticker:

停止Ticker，只是簡單的把Ticker從系統(tǒng)協(xié)程中移除。

函數(shù)主要實現(xiàn)如下：

func (t *Ticker) Stop() {
stopTimer(&t.r)
}

??stopTicker()?? 即通知系統(tǒng)協(xié)程把該 Ticker 移除，即不再監(jiān)控。系統(tǒng)協(xié)程只是移除 Ticker 并不會關(guān)閉管道，以避免用戶協(xié)程讀取錯誤。

Ticker 使用方式

例子一：

package main
import (
"fmt"
"time"
)
func main() {
TimeTicker := time.NewTicker(3 * time.Second)
tickerChannel := make(chan bool)
go func() {
for {
select {
case timeticker := <-TimeTicker.C:
fmt.Println("The time for current is : ", timeticker)
case <-tickerChannel:
return
}
}
}()
time.Sleep(6 * time.Second)
TimeTicker.Stop()
tickerChannel <- true
fmt.Println("Time for running ticker is completed")
}

運行該代碼：

$ go run main.go
The time for current is : 2022-04-29 22:37:13.93862 +0800 CST m=+3.000267823
The time for current is : 2022-04-29 22:37:16.939081 +0800 CST m=+6.000707515
Time for running ticker is completed

例子二：

package main
import (
"fmt"
"time"
)
func main() {
tm := time.Millisecond
tickerTicker := time.NewTicker(400 * tm)
tickerChaneel := make(chan bool)
go func() {
for {
select {
case <-tickerChaneel:
return
case tmtr := <-tickerTicker.C:
fmt.Println("Ticker time at current is", tmtr)
}
}
}()
time.Sleep(1400 * time.Millisecond)
tickerTicker.Stop()
tickerChaneel <- true
fmt.Println("Ticker has stopped now")
}

運行該代碼：

$ go run main.go
Ticker time at current is 2022-04-29 22:39:51.13057 +0800 CST m=+0.400159916
Ticker time at current is 2022-04-29 22:39:51.531516 +0800 CST m=+0.801102997
Ticker time at current is 2022-04-29 22:39:51.931238 +0800 CST m=+1.200822301
Ticker has stopped now