Go編寫定時器與定時任務(wù)詳解(附第三方庫gocron用法)
Go 編寫定時器和定時任務(wù)
在 項目開發(fā)當(dāng)中，可能會遇到這樣的場景:
1 A任務(wù)需要在多久之后執(zhí)行一次（定時器）
2.B任務(wù)需要每隔多長時間執(zhí)行一次 （定時任務(wù)）
談到定時任務(wù)，離不開linux的crontab. 先簡單了解下crontab
// 每隔1秒執(zhí)行一次 */1 * * * * ? // 每隔1分鐘執(zhí)行一次 0 */1 * * * ? // 每天0點執(zhí)行一次 0 0 0 * * ? // 每月1號凌晨1點執(zhí)行一次 0 0 1 1 * ? // 在1分、2分、3分執(zhí)行一次 0 1,2,3 * * * ? // 每天的0點、1點、2點執(zhí)行一次 0 0 0,1,2 * * ?
使用crontab實現(xiàn)定時器和定時任務(wù)也可以，但是crontab默認(rèn)只能精確到分鐘, 如果想要精確到秒可以使用for循環(huán)處理秒級人物
* * * * * for i in $(seq 1 11); do echo test >> /etc/demo/demo.txt; sleep 1; done
本文簡單介紹下go 實現(xiàn)定時器和定時任務(wù)的用法以及簡單介紹一個第三方庫gocron的用法
Timer
1 timer實現(xiàn)定時器 (延遲執(zhí)行), 這個定時器只會觸發(fā)一次.
使用于場景1（當(dāng)然如果把下面的代碼寫在一個for循環(huán)中也可以實現(xiàn)定時任務(wù)）
Demo:
package main
import (
"fmt"
"time"
)
func main() {
t := time.NewTimer(1 * time.Second)
<-t.C
fmt.Println("1 s 時間到")
}
結(jié)果:
1 s 時間到
2 停止定時器
使用time.Stop() 停止定時器
? 通過向通道發(fā)送一個信號，通知定時器是否關(guān)閉
Demo:
package main
import (
"fmt"
"time"
)
func test12(ch chan int) bool {
timer := time.NewTimer(1 * time.Second)
select {
case <-ch:
if timer.Stop() {
fmt.Println("關(guān)閉定時器")
}
return true
default:
fmt.Println("繼續(xù)執(zhí)行定時器")
return true
}
}
func main() {
ch := make(chan int, 1)
// ch <- 1
go test12(ch)
for {
}
}結(jié)果：
繼續(xù)執(zhí)行定時器
重置定時器
Demo:
func main() {
// 創(chuàng)建一個一個定時器
fmt.Println("定時器開始")
myT := time.NewTimer(7 * time.Second) // 設(shè)置7秒后執(zhí)行一次
// 重置定時器為 1s后執(zhí)行
myT.Reset(1 * time.Second)
<-myT.C
fmt.Println(" 1 s 時間到 ", time.Now().Unix())
for {
}
}
? 結(jié)果:
定時器開始
1 s 時間到 1648268475
Ticker
Ticker也是定時器，它是一個周期性的定時器 使用場景2
設(shè)置3秒執(zhí)行一次Demo
package main
import (
"fmt"
"time"
)
func main() {
ticker := time.NewTicker(3 * time.Second)
defer ticker.Stop()
for range ticker.C {
fmt.Println("執(zhí)行的業(yè)務(wù)邏輯")
}
}
結(jié)果:
ticker ticker ticker ...
ticker ticker ticker ...
ticker ticker ticker ...
gocron
一個第三方庫實現(xiàn)定時任務(wù) 場景2
安裝
go get -u github.com/go-co-op/gocron
s := gocron.NewScheduler(time.UTC)
s.Every(5).Seconds().Do(func(){ ... })
s.Every("5m").Do(func(){ ... })
s.Every(5).Days().Do(fu
s.Every(1).Month(1, 2, 3).Do(func(){ ... })
s.Every(1).Day().At("10:30").Do(func(){ ... })
s.Every(1).Day().At("10:30;08:00").Do(func(){ ... })
s.Every(1).Day().At("10:30").At("08:00").Do(func(){ ... })
s.Every(1).MonthLastDay().Do(func(){ ... })
s.Every(2).MonthLastDay().Do(func(){ ... })
s.Cron("*/1 * * * *").Do(task)
s.StartAsync()
s.StartBlocking()Demo
package main
import (
"fmt"
"time"
"github.com/go-co-op/gocron"
)
func cron1() {
fmt.Println("cron1")
}
func cron2() {
fmt.Println("cron2")
}
func main() {
timezone, _ := time.LoadLocation("Asia/Shanghai")
s := gocron.NewScheduler(timezone)
// 每秒執(zhí)行一次
s.Every(1).Seconds().Do(func() {
go cron1()
})
// 每秒執(zhí)行一次
s.Every(1).Second().Do(func() {
go cron2()
})
s.StartBlocking()
}結(jié)果:
cron2
cron1
cron1
cron2
cron1
cron2
cron1
cron2
總結(jié)
到此這篇關(guān)于Go編寫定時器與定時任務(wù)的文章就介紹到這了,更多相關(guān)Go定時器與定時任務(wù)內(nèi)容請搜索本站以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持本站！
版權(quán)聲明：本站文章來源標(biāo)注為YINGSOO的內(nèi)容版權(quán)均為本站所有，歡迎引用、轉(zhuǎn)載，請保持原文完整并注明來源及原文鏈接。禁止復(fù)制或仿造本網(wǎng)站，禁止在非www.sddonglingsh.com所屬的服務(wù)器上建立鏡像，否則將依法追究法律責(zé)任。本站部分內(nèi)容來源于網(wǎng)友推薦、互聯(lián)網(wǎng)收集整理而來，僅供學(xué)習(xí)參考，不代表本站立場，如有內(nèi)容涉嫌侵權(quán)，請聯(lián)系alex-e#qq.com處理。
關(guān)注官方微信