当前位置：首页 > 文章列表 > Golang > Go教程 > Go编写定时器与定时任务详解(附第三方库gocron用法)

Go编写定时器与定时任务详解(附第三方库gocron用法)

来源：脚本之家 2022-12-26 20:38:46 0浏览收藏

本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的，希望这篇《Go编写定时器与定时任务详解(附第三方库gocron用法)》对你有很大帮助！欢迎收藏，分享给更多的需要的朋友学习~

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)
	
<p>结果:</p>
<blockquote><p>1 s 时间到</p></blockquote>
<p><strong>2 停止定时器</strong></p>
<p>使用time.Stop() 停止定时器</p>
<p> 通过向通道发送一个信号，通知定时器是否关闭</p>
<p>Demo:</p>
<pre class="brush:go;">package main

import (
	"fmt"
	"time"
)

func test12(ch chan int) bool {
	timer := time.NewTimer(1 * time.Second)

	select {
	case 
<p>结果：</p>
<blockquote><p>继续执行定时器</p></blockquote>
<p><strong>重置定时器</strong></p>
<p>Demo:</p>
<pre class="brush:go;">func main() {
	// 创建一个一个定时器
	fmt.Println("定时器开始")
	myT := time.NewTimer(7 * time.Second) // 设置7秒后执行一次

	// 重置定时器为 1s后执行
	myT.Reset(1 * time.Second)
	
<p> 结果:</p>
<blockquote><p>定时器开始<br> 1 s 时间到  1648268475</p></blockquote>
<h2>Ticker</h2>
<p>Ticker也是定时器，它是一个周期性的定时器 使用场景2</p>
<p>设置3秒执行一次Demo</p>
<pre class="brush:go;">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()
}

结果: