脚本之家，脚本语言编程技术及教程分享平台！
分类导航

Python|VBS|Ruby|Lua|perl|VBA|Golang|PowerShell|Erlang|autoit|Dos|bat|

服务器之家 - 脚本之家 - Golang - Golang Cron 定时任务的实现示例

Golang Cron 定时任务的实现示例

2020-06-09 11:00jihite Golang

这篇文章主要介绍了Golang Cron 定时任务的实现示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧

开门见山写一个

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
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行

?
1
2
3
c := cron.New()
c.AddFunc("* * * * * *", CronTask)
c.Start()

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

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

?
1
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效果咋样呢？

?
1
2
3
4
5
6
7
8
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

按惯例先上个例子

?
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
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语句

再回到一开始的定时任务

回顾正题，定时原理解析

?
1
2
3
4
5
6
7
8
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 定时任务内容请搜索服务器之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持服务器之家！

原文链接：https://www.cnblogs.com/kaituorensheng/p/12812469.html

  • 定时任务
  • cron
  • golang

    • 延伸 · 阅读

    精彩推荐
    • GolangGolang中Bit数组的实现方式

      Golang中Bit数组的实现方式

      这篇文章主要介绍了Golang中Bit数组的实现方式，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...

      天易独尊11682021-06-09
    • Golanggolang 通过ssh代理连接mysql的操作

      golang 通过ssh代理连接mysql的操作

      这篇文章主要介绍了golang 通过ssh代理连接mysql的操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...

      a165861639710342021-03-08
    • Golanggo日志系统logrus显示文件和行号的操作

      go日志系统logrus显示文件和行号的操作

      这篇文章主要介绍了go日志系统logrus显示文件和行号的操作，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧...

      SmallQinYan12302021-02-02
    • Golanggo语言制作端口扫描器

      go语言制作端口扫描器

      本文给大家分享的是使用go语言编写的TCP端口扫描器，可以选择IP范围，扫描的端口，以及多线程，有需要的小伙伴可以参考下。 ...

      脚本之家3642020-04-25
    • Golanggolang json.Marshal 特殊html字符被转义的解决方法

      golang json.Marshal 特殊html字符被转义的解决方法

      今天小编就为大家分享一篇golang json.Marshal 特殊html字符被转义的解决方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧 ...

      李浩的life12792020-05-27
    • Golanggolang的httpserver优雅重启方法详解

      golang的httpserver优雅重启方法详解

      这篇文章主要给大家介绍了关于golang的httpserver优雅重启的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，...

      helight2992020-05-14
    • GolangGolang通脉之数据类型详情

      Golang通脉之数据类型详情

      这篇文章主要介绍了Golang通脉之数据类型，在编程语言中标识符就是定义的具有某种意义的词，比如变量名、常量名、函数名等等，Go语言中标识符允许由...

      羌4272021-11-24
    • Golanggolang如何使用struct的tag属性的详细介绍

      golang如何使用struct的tag属性的详细介绍

      这篇文章主要介绍了golang如何使用struct的tag属性的详细介绍，从例子说起，小编觉得挺不错的，现在分享给大家，也给大家做个参考。一起跟随小编过来看...

      Go语言中文网11352020-05-21
    最近更新
    编辑推荐
    阅读排行
    热门标签
    gosublime 　 指针类型 　 new() 　 make() 　 并发模型 　 切片 　 静态WEB服务器 　 端口扫描器 　 Go语言入门教程 　 基础语 　 Slices 　 Maps 　 Golang编程 　 panic 　 接受者类型 　 嵌入类型 　 Slice 　 Golang教程 　 Golang项目 　 内存模型 　 开发环境搭建 　 大小端判断 　 代码组织结构 　 复合类型 　 GOPATH 　 工作目录 　 实例 　 struct类型 　 并发技术 　 buffered 　
    © 2019-2023 脚本之家 | 服务器之家(www.zzvips.com)旗下站点 版权所有关于我们联系我们版权申明网站地图