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