Huangzj
67 lines
959 B
Go
67 lines
959 B
Go
/*
|
||
* @Author : huangzj
|
||
* @Time : 2020/12/16 17:10
|
||
* @Description：
|
||
*/
|
||
|
||
package cron
|
||
|
||
import (
|
||
"fmt"
|
||
"github.com/robfig/cron"
|
||
"log"
|
||
"testing"
|
||
)
|
||
|
||
//测试单个定时任务
|
||
func TestCron(t *testing.T) {
|
||
i := 0
|
||
c := cron.New()
|
||
spec := "0 */1 * * * ?" //一分钟运行一次
|
||
_ = c.AddFunc(spec, func() {
|
||
i++
|
||
fmt.Println("cron running:", i)
|
||
})
|
||
c.Start()
|
||
|
||
select {}
|
||
}
|
||
|
||
//多个定时任务
|
||
func TestMoreCron(t *testing.T) {
|
||
i := 0
|
||
c := cron.New()
|
||
//AddFunc
|
||
spec := "*/5 * * * * ?"
|
||
_ = c.AddFunc(spec, func() {
|
||
i++
|
||
log.Println("cron running:", i)
|
||
})
|
||
|
||
//AddJob方法
|
||
_ = c.AddJob(spec, TestJob{})
|
||
_ = c.AddJob(spec, Test2Job{})
|
||
|
||
//启动计划任务
|
||
c.Start()
|
||
|
||
//关闭着计划任务, 但是不能关闭已经在执行中的任务.
|
||
defer c.Stop()
|
||
|
||
select {}
|
||
}
|
||
|
||
type TestJob struct {
|
||
}
|
||
|
||
func (t TestJob) Run() {
|
||
fmt.Println("testJob1...")
|
||
}
|
||
|
||
type Test2Job struct {
|
||
}
|
||
|
||
func (t Test2Job) Run() {
|
||
fmt.Println("testJob2...")
|
||
}
|