登录
首页 >  Golang >  Go教程

Golang Cron 定时任务的实现示例

来源:脚本之家

时间:2023-01-07 11:53:05 324浏览 收藏

在Golang实战开发的过程中,我们经常会遇到一些这样那样的问题,然后要卡好半天,等问题解决了才发现原来一些细节知识点还是没有掌握好。今天golang学习网就整理分享《Golang Cron 定时任务的实现示例》,聊聊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 

核心的定时器代码就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 

输出

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、"hello"不定

select 语法

每个case都必须是个通信

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

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

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

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

再回到一开始的定时任务

回顾正题,定时原理解析

t1 := time.NewTimer(time.Second * 10) 
  for {
    select {
    case 

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

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

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

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

今天带大家了解了cron、定时任务的相关知识,希望对你有所帮助;关于Golang的技术知识我们会一点点深入介绍,欢迎大家关注golang学习网公众号,一起学习编程~

声明:本文转载于:脚本之家 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>
评论列表