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