Cron常见用法

  • 每隔5分钟执行: /5 *
  • 第1-5分钟执行5次: 1-5
  • 每天10点, 22点整执行一次: 0 10,22 *

开源项目: https://github.com/gorhill/cronexpr

  • cronexpr 支持秒粒度 粒度年

  • parse, err := cronexpr.Parse(*/5 * * * * * *) // 每5秒

    1. func main() {
    2.   // linux 分钟, 小时, 天, 月, 星期几
    4.   // cronexpr 支持秒粒度 粒度年
    5.   parse, err := cronexpr.Parse(`*/5 * * * * * *`)
    7.   if err == nil {
    8.       // 下次调度时间
    9.       next := parse.Next(time.Now())
    11.       time.AfterFunc(next.Sub(time.Now()), func() {
    12.           fmt.Println("被调度了...")
    13.       })
    14.   }
    16.   time.Sleep(5 * time.Second)
    17. }

调度多个任务

  2. type CronJob struct {
  3.     expr     *cronexpr.Expression
  4.     nextTime time.Time
  5. }
  7. func main() {
  9.     scheduleTable := make(map[string]*CronJob)
  11.     // 执行过期的任务
  12.     expr := cronexpr.MustParse(`*/5 * * * * * *`)
  13.     cronJob := &CronJob{
  14.         expr:     expr,
  15.         nextTime: expr.Next(time.Now()),
  16.     }
  17.     scheduleTable["job1"] = cronJob
  19.     expr2 := cronexpr.MustParse(`*/5 * * * * * *`)
  20.     cronJob2 := &CronJob{
  21.         expr:     expr2,
  22.         nextTime: expr2.Next(time.Now()),
  23.     }
  24.     scheduleTable["job2"] = cronJob2
  26.     go func() {
  27.         for {
  28.             now := time.Now()
  29.             for jobName, cronJob := range scheduleTable {
  30.                 if cronJob.nextTime.Before(now) || cronJob.nextTime.Equal(now) {
  31.                     // 启动一个协程, 执行这个任务
  32.                     go func(jobName string) {
  33.                         fmt.Println("执行: ", jobName)
  34.                     }(jobName)
  36.                     // 计算下一次调度时间
  37.                     cronJob.nextTime = cronJob.expr.Next(now)
  38.                     fmt.Println("下次执行时间: ", cronJob.nextTime)
  39.                 }
  40.             }
  42.             select {
  43.             case <-time.NewTimer(100 * time.Millisecond).C: // 100ms毫秒可读
  44.             }
  45.         }
  46.     }()
  48.     time.Sleep(100 * time.Second)
  49. }