Golang Cron 定时任务的实现示例

开门见山写一个

package main

import (
  "fmt"
  "github.com/robfig/cron"
  "log"
  "strings"
  "time"
)

func crontask() {
  log.println("******** ******* *******")
}

func crontest() {
  log.println("starting cron...")

  c := cron.new()
  c.addfunc("* * * * * *", crontask) //2 * * * * *, 2 表示每分钟的第2s执行一次
  c.start()

  t1 := time.newtimer(time.second * 10) // ?time.second * 10 啥意思？ *100行吗？
  for {
    select {
    case <-t1.c:
      fmt.println("time now:", time.now().format("2006-01-02 15:04:05")) // 为何要专门制定这个时间
      t1.reset(time.second * 10)
    }
  }
}

func main() {
  fmt.println(strings.repeat("start ", 15))
  crontest()
  fmt.println(strings.repeat("end ", 15))
}

核心的定时器代码就3行

c := cron.new()
c.addfunc("* * * * * *", crontask)
c.start()

那后面那些代码时作甚的？

一开始看到示例代码时，有个疑惑，如代码中注释

t1 := time.newtimer(time.second * 10)

这里time.second*10是干啥的？ 是否可以写成*100呢， 改了后原来是可以的，那更疑惑了既然都行为啥还要写个这个？

还有后面的for-select-case也是一脸懵逼~~~~

运行代码，从结果反推下原理吧，一次执行结果

start start start start start start start start start start start start start start start
2020/05/01 07:38:07 starting cron...
2020/05/01 07:38:08 ********  *******  *******
2020/05/01 07:38:09 ********  *******  *******
2020/05/01 07:38:10 ********  *******  *******
2020/05/01 07:38:11 ********  *******  *******
2020/05/01 07:38:12 ********  *******  *******
2020/05/01 07:38:13 ********  *******  *******
2020/05/01 07:38:14 ********  *******  *******
2020/05/01 07:38:15 ********  *******  *******
2020/05/01 07:38:16 ********  *******  *******
2020/05/01 07:38:17 ********  *******  *******
time now: 2020-05-01 07:38:17
2020/05/01 07:38:18 ********  *******  *******
2020/05/01 07:38:19 ********  *******  *******
2020/05/01 07:38:20 ********  *******  *******
2020/05/01 07:38:21 ********  *******  *******
2020/05/01 07:38:22 ********  *******  *******
2020/05/01 07:38:23 ********  *******  *******
2020/05/01 07:38:24 ********  *******  *******
2020/05/01 07:38:25 ********  *******  *******
2020/05/01 07:38:26 ********  *******  *******
2020/05/01 07:38:27 ********  *******  *******
time now: 2020-05-01 07:38:27
2020/05/01 07:38:28 ********  *******  *******

以上是运行的片段，有两大发现

1. 有start start start。。。没有end end end 。。。。：说明了代码在执行时阻塞在定时器里，定时器没有执行完，永远不会执行end
2. time now打出来的间隔正好是10s

哦，原来time.newtimer是个定时器，当这个时间间隔完了后再重新打开一个。for-select-case 这一块目的是阻塞流程，不让程序结束。 理解对吗

如果是这样，去掉for-select-case 执行第一个定时器时也可以停10s,是这样吗？试验下：屏蔽掉for-select-case, 输出

start start start start start start start start start start start start start start start
2020/05/01 07:56:22 starting cron...
end end end end end end end end end end end end end end end

打脸了，看来阻塞主要靠for-select-case实现，那原理是什么呢？

去掉t1.reset效果咋样呢？

t1 := time.newtimer(time.second * 10) // ?time.second * 10 啥意思？ *100行吗？
  for {
    fmt.println("hihihihi")
    select {
    case <-t1.c:
      fmt.println("hello")
    }
  }

输出

start start start start start start start start start start start start start start start
2020/05/01 08:12:21 starting cron...
hihihihi
2020/05/01 08:12:22 ********  *******  *******
2020/05/01 08:12:23 ********  *******  *******
2020/05/01 08:12:24 ********  *******  *******
2020/05/01 08:12:25 ********  *******  *******
2020/05/01 08:12:26 ********  *******  *******
2020/05/01 08:12:27 ********  *******  *******
2020/05/01 08:12:28 ********  *******  *******
2020/05/01 08:12:29 ********  *******  *******
2020/05/01 08:12:30 ********  *******  *******
2020/05/01 08:12:31 ********  *******  *******
hello
hihihihi
2020/05/01 08:12:32 ********  *******  *******
2020/05/01 08:12:33 ********  *******  *******
2020/05/01 08:12:34 ********  *******  *******
2020/05/01 08:12:35 ********  *******  *******
2020/05/01 08:12:36 ********  *******  *******

更蒙了，去掉reset, 运行完第一个定时器10s, 非但没听，还直接执行起来了，没停了

for 循环里的print不是刷刷的一大片，而是和case命中时一期打，看来是时候了解下select-case的原理了

select case

按惯例先上个例子

package main

import (
  "fmt"
  "strings"
)

func selecttest() {
  intchan := make(chan int, 1)
  stringchan := make(chan string, 1)
  intchan <- 123456
  stringchan <- "hello"

  select {
  case value := <-intchan:
    fmt.println(value)
  case value := <- stringchan:
    fmt.println(value)
  }
}

func main() {
  fmt.println(strings.repeat("start ", 15))
  selecttest()
  fmt.println(strings.repeat("end ", 15))
}

执行多次可以看到，输出的结果是 123456、"hello"不定

select 语法

每个case都必须是个通信

如果一个通信可进行它就执行，其他被忽略

如果有多个case可执行，就会随机的选择一个执行

如果没有case可执行，如果如果有default，执行default语句；否则就阻塞，直到有某个通信可行

这里还是有很多问题， 单开一节弄清楚 select语句

再回到一开始的定时任务

回顾正题，定时原理解析

t1 := time.newtimer(time.second * 10) 
  for {
    select {
    case <-t1.c:
      fmt.println("time now:", time.now().format("2006-01-02 15:04:05"))
      t1.reset(time.second * 10)
    }
  }

• 生成一个定时器t1, 执行for循环，一开始定时时间（10s）未到, 也没有阻塞任务，它就阻塞在case中；
• 定时时间到了，则执行case中语句；
• 然后又重新恢复定时时长
• 重新走for循环，还是重复上面的故事

上面代码中尝试把case中的t1.reset去掉，结果也是定时任务不同的执行，原因是执行case中的语句后，接着执行for循环，由于没有新通信过来（case语句永远无法满足），同时没有default语句，所以同样可以阻塞再次。

相比在case中t1 reset， t1 reset更灵活些，因为可以再每次重新满足case时做一些灵活的操作，比如跳出循环，做一些统计打印等。

 到此这篇关于golang cron 定时任务的实现示例的文章就介绍到这了,更多相关golang cron 定时任务内容请搜索以前的文章或继续浏览下面的相关文章希望大家以后多多支持！