很多人都用過linux的定時任務,舉個例子,我們有一個任務需要每隔1分鐘運行一次,如果使用Linux的crontab可以用 * * * * *表示,這是系統級的定時器。
在Go標準庫里面也有類似的功能實現,我們稱之為定時器,非常簡單易用,用途非常廣泛,下面咱就看一下怎么用吧!
舉個例子,這里使用time包里面的ticker實現:
package main
import (
"log"
"time"
)
func main() {
log.Println("等待10秒鐘。。。")
ticker := time.NewTicker(10 * time.Second)
<-ticker.C
log.Println("執行")
}
執行結果如下:
2020/06/18 21:53:31 等待10秒鐘。。。
2020/06/18 21:53:41 執行
1.for…select
假設我們想實現一種定時執行的效果,只要把它放到一個for循環里面即可:
func main() {
ticker := time.NewTicker(10 * time.Second)
for {
<-ticker.C
log.Println("執行")
}
}
但是我們通常更常見的一種寫法是配合select使用,其實如果只是一個定時任務,這2者沒什么差異。
func main() {
ticker := time.NewTicker(10 * time.Second)
for {
select {
case <-ticker.C:
log.Println("執行")
}
}
}
2.注意的坑
很多人以為這個定時任務和Linux的一樣,是定時執行的,舉個例子,我們有2個定時器,一個10s執行一次,1個20s執行一次,一般是這樣寫:
func main() {
t1 := time.NewTicker(10 * time.Second)
t2 := time.NewTicker(20 * time.Second)
for {
select {
case <-t1.C:
log.Println("執行10s")
// time.Sleep(15*time.Second)
case <-t2.C:
log.Println("執行20s")
}
}
}
但是,假如第一個10s的任務執行耗時超過了20s,那么多第二個定時任務就無法按時執行了。
2020/06/18 22:23:25 執行10s
2020/06/18 22:23:50 執行20s
2020/06/18 22:23:50 執行10s
2020/06/18 22:24:15 執行10s
2020/06/18 22:24:40 執行20s
2020/06/18 22:24:40 執行10s
究其原因,是因為select在同一時間只能選擇一個分支執行,當你前面那個分支任務“阻塞“住了,就無法抽出空來執行第二個任務,即使已經過了定時器設定的時間。
熟悉Linux的crontab定時任務的人知道,它不會管你上一個任務有沒有執行完成,會“非常準時”的執行。
在上面這個例子,由于select是隨機選擇一個分支執行,所以你會發現這2個任務并不是交互執行,比如上面的例子里面,10s執行了2次。
所以嚴格依賴定時的任務得考慮任務本身執行耗費的時間,不然可能會得到你預想之外的結果,其實有一個非常簡單的方法可以解決這個問題,我們只要把需要執行的任務用go啟動一個協程去執行即可。
3.timer延遲執行
細心的人注意了,time包里面還有一個timer,它和這個ticker有啥區別呢?tick原指機械鐘表指針轉動的聲音,它表示的意思是每隔固定的時間段做一件事。
而timer則是“定時炸彈”的定時,只不過它只執行一次(定時炸彈炸完就沒),某些時候是和之前的ticker一樣,比如延遲執行:
package main
import (
"log"
"time"
)
func main() {
log.Println("等待10秒鐘。。。")
timer := time.NewTimer(10 * time.Second)
<-timer.C
log.Printf("執行")
}
有人說,這和我寫個time.Sleep(10 * time.Second)有啥區別?這個。。。有待研究!
這個包里面還有2個等價的簡化寫法:
func main() {
log.Println("等待10秒鐘。。。")
<-time.After(10*time.Second)
//time.AfterFunc(10*time.Second, func() {
// log.Printf("執行")
//})
log.Printf("執行")
}
那這個timer存在的意義到底在哪呢?
首先,這個timer是一次性的,所以沒法像之前那樣放到for循環里面來實現定時執行的功能。
其次,除了可以作為一個一次性延遲執行功能之外,還可以作為一個實現超時的功能,舉個例子,從一個管道中等待獲取數據。

package main
import (
"fmt"
"time"
)
func main() {
ch1 := make(chan int)
t := time.NewTimer(5 * time.Second)
select {
case <-ch1:
t.Stop()
//do something....
case <-t.C:
fmt.Println("5s已經過去,任務超時")
}
}
關于Go定時器的介紹就說這么多,下次再說說其內部實現原理。