golang 定时任务处理
·
在 golang 中若写定时脚本,有两种实现。
一、基于原生语法组装
func DocSyncTaskCronJob() {
ticker := time.NewTicker(time.Minute * 1) // 每分钟执行一次
for range ticker.C {
ProcTask()
}
}
func ProcTask() {
log.Println("hello world")
}
二、基于 github 中封装的 cron 库实现
package task
import (
"github.com/robfig/cron/v3"
"log"
)
// Task 任务
type Task struct {
}
var taskMap = make(map[string]func())
func init() {
taskMap["procTask"] = ProcTask
}
func ProcTask() {
log.Println("hello world")
}
// Init 初始化
func Init() (obj *Task) {
obj = &Task{}
return
}
// Execute 执行任务
func (obj *Task) Execute() {
crontabList := make(map[string]string)
// 每分钟执行一次
// https://crontab.guru/ 检测 crontab 准确率
crontabList["procTask"] = "0 */1 * * * *"
c := cron.New(cron.WithSeconds())
log.Println(crontabList)
for key, value := range crontabList {
if _, ok := taskMap[key]; ok {
_, err := c.AddFunc(value, taskMap[key])
if err != nil {
log.Println("Execute task AddFunc Failed, err=" + err.Error())
}
}
}
go c.Start()
defer c.Stop()
}
更多推荐
已为社区贡献4条内容
所有评论(0)