github 的地址如下: https://github.com/yukongco/cron
基于 github.com/robfig/cron 的一个改进版本, 在原有基础上支持带 jobname 的定时器,
方便删除定时器中的任务。
带 jobname 的定时器如下所示
测试例子如下:
package testcrontab
import ( "fmt" "time"
"github.com/yukongco/cron" )
func print1() {
fmt.Println("111 now time: ", time.Now().Format(Time_Format))
}
func printa() {
fmt.Println("aaa now time: ", time.Now().Format(Time_Format))
}
func printb() {
fmt.Println("bbb now time: ", time.Now().Format(Time_Format))
}
func printc() {
fmt.Println("ccc now time: ", time.Now().Format(Time_Format))
}
func main() {
fmt.Println("12-22 */1") cronRes := cron.New()
// 不带 jobname 的定时器 cronRes.AddFunc("/2 * ?", print1)
// 带 jobname 的定时器 cronRes.AddFuncWithName("/2 ?", printa, "aaa") cronRes.AddFuncWithName("/2 ?", printb, "bbb")
cronRes.Start() defer cronRes.Stop()
time.Sleep(4 time.Second) cronRes.AddFuncWithName("/2 ?", printc, "ccc")
// 删除名字为 bbb的 job err := cronRes.RemoveJob("bbb") if err != nil { fmt.Println("remove job is err: ", err) return }
time.Sleep(4 * time.Second)
return
}
有疑问加站长微信联系(非本文作者)
