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
<p>核心的定时器代码就3行</p>
<pre class="brush:plain;">
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 ******** ******* *******
以上是运行的片段,有两大发现
- 有START START START。。。没有END END END 。。。。:说明了代码在执行时阻塞在定时器里,定时器没有执行完,永远不会执行END
- 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
<p>输出</p>
<blockquote>
<p>START START START START START START START START START START START START START START START <br>
2020/05/01 08:12:21 Starting Cron...<br>
hihihihi<br>
2020/05/01 08:12:22 ******** ******* *******<br>
2020/05/01 08:12:23 ******** ******* *******<br>
2020/05/01 08:12:24 ******** ******* *******<br>
2020/05/01 08:12:25 ******** ******* *******<br>
2020/05/01 08:12:26 ******** ******* *******<br>
2020/05/01 08:12:27 ******** ******* *******<br>
2020/05/01 08:12:28 ******** ******* *******<br>
2020/05/01 08:12:29 ******** ******* *******<br>
2020/05/01 08:12:30 ******** ******* *******<br>
2020/05/01 08:12:31 ******** ******* *******<br>
hello<br>
hihihihi<br>
2020/05/01 08:12:32 ******** ******* *******<br>
2020/05/01 08:12:33 ******** ******* *******<br>
2020/05/01 08:12:34 ******** ******* *******<br>
2020/05/01 08:12:35 ******** ******* *******<br>
2020/05/01 08:12:36 ******** ******* *******<br></p>
</blockquote>
<p>更蒙了,去掉reset, 运行完第一个定时器10s, 非但没听,还直接执行起来了,没停了</p>
<p>for 循环里的print不是刷刷的一大片,而是和case命中时一期打,看来是时候了解下select-case的原理了</p>
<p><span style="color: #ff0000"><strong>select case</strong></span><br></p>
<p>按惯例先上个例子</p>
<pre class="brush:plain;">
package main
import (
"fmt"
"strings"
)
func SelectTest() {
intChan := make(chan int, 1)
stringChan := make(chan string, 1)
intChan
<p>执行多次可以看到,输出的结果是 123456、"hello"不定</p>
<p><span style="color: #000000"><strong>select 语法</strong></span><br></p>
<p>每个case都必须是个通信</p>
<p>如果一个通信可进行它就执行,其他被忽略</p>
<p>如果有多个case可执行,就会随机的选择一个执行</p>
<p>如果没有case可执行,如果如果有default,执行default语句;否则就阻塞,直到有某个通信可行</p>
<p>这里还是有很多问题, 单开一节弄清楚 select语句</p>
<p>再回到一开始的定时任务</p>
<p><span style="color: #ff0000"><strong>回顾正题,定时原理解析<br></strong></span></p>
<pre class="brush:plain;">
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学习网公众号,一起学习编程~
-
190 收藏
-
208 收藏
-
250 收藏
-
444 收藏
-
309 收藏
-
379 收藏
-
119 收藏
-
140 收藏
-
147 收藏
-
378 收藏
-
255 收藏
-
287 收藏
-
393 收藏
-
310 收藏
-
110 收藏
-
412 收藏
-
423 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 485次学习