Go编写定时器与定时任务详解(附第三方库gocron用法)
作者:太阳上的雨天 发布时间:2024-05-09 09:40:19
标签:go,定时器,定时任务
Go 编写定时器和定时任务
在 项目开发当中,可能会遇到这样的场景:
1 A任务需要在多久之后执行一次(定时器)
2.B任务需要每隔多长时间执行一次 (定时任务)
谈到定时任务,离不开linux的crontab. 先简单了解下crontab
// 每隔1秒执行一次
*/1 * * * * ?
// 每隔1分钟执行一次
0 */1 * * * ?
// 每天0点执行一次
0 0 0 * * ?
// 每月1号凌晨1点执行一次
0 0 1 1 * ?
// 在1分、2分、3分执行一次
0 1,2,3 * * * ?
// 每天的0点、1点、2点执行一次
0 0 0,1,2 * * ?
使用crontab实现定时器和定时任务也可以,但是crontab默认只能精确到分钟, 如果想要精确到秒可以使用for循环处理秒级人物
* * * * * for i in $(seq 1 11); do echo test >> /etc/demo/demo.txt; sleep 1; done
本文简单介绍下go 实现定时器和定时任务的用法以及简单介绍一个第三方库gocron的用法
Timer
1 timer实现定时器 (延迟执行), 这个定时器只会触发一次.
使用于场景1(当然如果把下面的代码写在一个for循环中也可以实现定时任务)
Demo:
package main
import (
"fmt"
"time"
)
func main() {
t := time.NewTimer(1 * time.Second)
<-t.C
fmt.Println("1 s 时间到")
}
结果:
1 s 时间到
2 停止定时器
使用time.Stop() 停止定时器
? 通过向通道发送一个信号,通知定时器是否关闭
Demo:
package main
import (
"fmt"
"time"
)
func test12(ch chan int) bool {
timer := time.NewTimer(1 * time.Second)
select {
case <-ch:
if timer.Stop() {
fmt.Println("关闭定时器")
}
return true
default:
fmt.Println("继续执行定时器")
return true
}
}
func main() {
ch := make(chan int, 1)
// ch <- 1
go test12(ch)
for {
}
}
结果:
继续执行定时器
重置定时器
Demo:
func main() {
// 创建一个一个定时器
fmt.Println("定时器开始")
myT := time.NewTimer(7 * time.Second) // 设置7秒后执行一次
// 重置定时器为 1s后执行
myT.Reset(1 * time.Second)
<-myT.C
fmt.Println(" 1 s 时间到 ", time.Now().Unix())
for {
}
}
? 结果:
定时器开始
1 s 时间到 1648268475
Ticker
Ticker也是定时器,它是一个周期性的定时器 使用场景2
设置3秒执行一次Demo
package main
import (
"fmt"
"time"
)
func main() {
ticker := time.NewTicker(3 * time.Second)
defer ticker.Stop()
for range ticker.C {
fmt.Println("执行的业务逻辑")
}
}
结果:
ticker ticker ticker ...
ticker ticker ticker ...
ticker ticker ticker ...
gocron
一个第三方库实现定时任务 场景2
安装
go get -u github.com/go-co-op/gocron
s := gocron.NewScheduler(time.UTC)
s.Every(5).Seconds().Do(func(){ ... })
s.Every("5m").Do(func(){ ... })
s.Every(5).Days().Do(fu
s.Every(1).Month(1, 2, 3).Do(func(){ ... })
s.Every(1).Day().At("10:30").Do(func(){ ... })
s.Every(1).Day().At("10:30;08:00").Do(func(){ ... })
s.Every(1).Day().At("10:30").At("08:00").Do(func(){ ... })
s.Every(1).MonthLastDay().Do(func(){ ... })
s.Every(2).MonthLastDay().Do(func(){ ... })
s.Cron("*/1 * * * *").Do(task)
s.StartAsync()
s.StartBlocking()
Demo
package main
import (
"fmt"
"time"
"github.com/go-co-op/gocron"
)
func cron1() {
fmt.Println("cron1")
}
func cron2() {
fmt.Println("cron2")
}
func main() {
timezone, _ := time.LoadLocation("Asia/Shanghai")
s := gocron.NewScheduler(timezone)
// 每秒执行一次
s.Every(1).Seconds().Do(func() {
go cron1()
})
// 每秒执行一次
s.Every(1).Second().Do(func() {
go cron2()
})
s.StartBlocking()
}
结果:
cron2
cron1
cron1
cron2
cron1
cron2
cron1
cron2
来源:https://blog.csdn.net/weixin_43713498/article/details/123750660
0
投稿
猜你喜欢
- 导包效果展示以下截图显示的撤回消息类型依次是文字消息、微信自带表情、图片、语音、定位地图、名片、公众号文章、音乐、视频。有群里撤回的,也有个
- 这是一家游戏公司,他面试通过后 擅长的机试却没答出来,不过还是被录用了。这道题内容大概这样有条蛇它长度不固定,蛇头朝北顺时针盘旋着,请打印出
- 在asp里通过以下两个函数实现javascript里的escape函数和unescape函数
- 前言如果你在寻找python工作,那你的面试可能会涉及Python相关的问题。通过对网络资料的收集整理,本文列出了100道python的面试
- 本文实例讲述了Python实现的网页截图功能。分享给大家供大家参考,具体如下:方法一、使用PyQt4的QtWebKit组件#!/usr/bi
- 1 椭圆肤色检测模型原理:将RGB图像转换到YCRCB空间,肤色像素点会聚集到一个椭圆区域。先定义一个椭圆模型,然后将每个RGB像素点转换到
- iamlaosong文曾经看到这样一个问题,一个字典中的元素是列表,将这个列表元素赋值给一个变量,然后修改这个列表中元素的值,结果发现,字典
- 环境搭建1.首先需要自行安装node环境2.然后全局安装 expressnpm install -g express3.创建express项
- 你可能正建立自己在网上的家-WEB页,又或者它已经被你安置在网络某一角里。无论出于什么目的,你都希望有
- 1. 换源,sohu的相当好用。 1.1备份CentOS-Base.repo cd /etc/yum.repos.d/ cp CentOS-
- 由于该math模块与 Python 版本一起打包,因此您不必单独安装它,直接导入:import mathmath模块常数Pythonmath
- 前言在ES6新增的数组方法中,包含了多个遍历方法,其中包含了用于筛选的filter和reducefilter主要用于筛选数组的filter方
- 详解Python文本操作相关模块linecache——通过使用缓存在内部尝试优化以达到高效从任何文件中读出任何行。 主要方法: lineca
- list解析先看下面的例子,这个例子是想得到1到9的每个整数的平方,并且将结果放在list中打印出来>>> power2
- 编写兼容IE和FireFox的脚本确定的件很烦人的事,今日又经历了一次。一、正式表达式问题试图用以下表达式提取中括号“]”后面的内容,连接调
- <!DOCTYPE html> <html lang="en" xmlns="http://
- 1、如果同时从同一个客户端插入很多行,使用含多个 VALUE的INSERT语句同时插入几行。这比使用单行INSERT语句快(在某些情况下快几
- 目前python 提供了几种多线程实现方式 thread,threading,multithreading ,其中thread模块比较底层,
- 概述nodejs内置模块指的是除默认提供的语法之外,提供的美容,无需下载,直接引入,引入只写名称即可。nodejs内置模块:1、path模块
- 本文为大家分享了python3.5.1安装教程的具体步骤,供大家参考,具体内容如下首先,找到python下载的地址,如下图所示在这里我选择了