包获取
go get -u github.com/gorhill/cronexpr
创建一个定时任务
expr, err = cron.Parse("* * * * *");
获得任务的下次执行时间
nextTime = expr.Next(now)
package main import (
"fmt"
"time"
cron "github.com/gorhill/cronexpr"
) type CronJob struct {
expr *cron.Expression
nextTime time.Time //expr.now
} func main() { var (
cronJob *CronJob
expr *cron.Expression
now time.Time
scheduleTable map[string]*CronJob // key 任务的名称
) scheduleTable = make(map[string]*CronJob) now = time.Now()
expr = cron.MustParse("*/5 * * * * * *") cronJob = &CronJob{
expr: expr,
nextTime: expr.Next(now),
} scheduleTable["job1"] = cronJob expr = cron.MustParse("*/10 * * * * * *") cronJob = &CronJob{
expr: expr,
nextTime: expr.Next(now),
} // 将任务注册到调度表中 scheduleTable["job2"] = cronJob // 调度协程
go func() {
var(
_now time.Time
cname string
cronjob *CronJob
) for {
_now = time.Now()
for cname, cronjob = range scheduleTable {
if cronjob.nextTime.Before(_now) || cronjob.nextTime.Equal(_now) {
go func(name string) {
fmt.Println("exec", name)
}(cname) cronjob.nextTime = cronjob.expr.Next(_now)
fmt.Println("next exec time: ",cronjob.nextTime)
}
} select {
case <-time.NewTimer(100 * time.Millisecond).C: //睡眠
}
}
}() time.Sleep(time.Minute*3)
}