Go編寫定時(shí)器與定時(shí)任務(wù)詳解(附第三方庫(kù)gocron用法)

第Go編寫定時(shí)器與定時(shí)任務(wù)詳解(附第三方庫(kù)gocron用法)目錄Go編寫定時(shí)器和定時(shí)任務(wù)TimerTickergocron安裝Demo總結(jié)

Go編寫定時(shí)器和定時(shí)任務(wù)

在項(xiàng)目開發(fā)當(dāng)中，可能會(huì)遇到這樣的場(chǎng)景:

1A任務(wù)需要在多久之后執(zhí)行一次（定時(shí)器）

2.B任務(wù)需要每隔多長(zhǎng)時(shí)間執(zhí)行一次（定時(shí)任務(wù)）

談到定時(shí)任務(wù)，離不開linux的crontab.先簡(jiǎn)單了解下crontab

//每隔1秒執(zhí)行一次

*/1****

//每隔1分鐘執(zhí)行一次

0*/1***

//每天0點(diǎn)執(zhí)行一次

000**

//每月1號(hào)凌晨1點(diǎn)執(zhí)行一次

0011*

//在1分、2分、3分執(zhí)行一次

01,2,3***

//每天的0點(diǎn)、1點(diǎn)、2點(diǎn)執(zhí)行一次

000,1,2**

使用crontab實(shí)現(xiàn)定時(shí)器和定時(shí)任務(wù)也可以，但是crontab默認(rèn)只能精確到分鐘,如果想要精確到秒可以使用for循環(huán)處理秒級(jí)人物

*****foriin$(seq111);doechotest/etc/demo/demo.txt;sleep1;done

本文簡(jiǎn)單介紹下go實(shí)現(xiàn)定時(shí)器和定時(shí)任務(wù)的用法以及簡(jiǎn)單介紹一個(gè)第三方庫(kù)gocron的用法

Timer

1timer實(shí)現(xiàn)定時(shí)器(延遲執(zhí)行),這個(gè)定時(shí)器只會(huì)觸發(fā)一次.

使用于場(chǎng)景1（當(dāng)然如果把下面的代碼寫在一個(gè)for循環(huán)中也可以實(shí)現(xiàn)定時(shí)任務(wù)）

Demo:

packagemain

import(

"fmt"

"time"

funcmain(){

t:=time.NewTimer(1*time.Second)

-t.C

fmt.Println("1s時(shí)間到")

結(jié)果:

1s時(shí)間到

2停止定時(shí)器

使用time.Stop()停止定時(shí)器

?通過(guò)向通道發(fā)送一個(gè)信號(hào)，通知定時(shí)器是否關(guān)閉

Demo:

packagemain

import(

"fmt"

"time"

functest12(chchanint)bool{

timer:=time.NewTimer(1*time.Second)

select{

case-ch:

iftimer.Stop(){

fmt.Println("關(guān)閉定時(shí)器")

returntrue

default:

fmt.Println("繼續(xù)執(zhí)行定時(shí)器")

returntrue

funcmain(){

ch:=make(chanint,1)

//ch-1

gotest12(ch)

for{

}

結(jié)果：

繼續(xù)執(zhí)行定時(shí)器

重置定時(shí)器

Demo:

funcmain(){

//創(chuàng)建一個(gè)一個(gè)定時(shí)器

fmt.Println("定時(shí)器開始")

myT:=time.NewTimer(7*time.Second)//設(shè)置7秒后執(zhí)行一次

//重置定時(shí)器為1s后執(zhí)行

myT.Reset(1*time.Second)

-myT.C

fmt.Println("1s時(shí)間到",time.Now().Unix())

for{

?結(jié)果:

定時(shí)器開始

1s時(shí)間到1648268475

Ticker

Ticker也是定時(shí)器，它是一個(gè)周期性的定時(shí)器使用場(chǎng)景2

設(shè)置3秒執(zhí)行一次Demo

packagemain

import(

"fmt"

"time"

funcmain(){

ticker:=time.NewTicker(3*time.Second)

deferticker.Stop()

forrangeticker.C{

fmt.Println("執(zhí)行的業(yè)務(wù)邏輯")

結(jié)果:

tickertickerticker...

tickertickerticker...

tickertickerticker...

gocron

一個(gè)第三方庫(kù)實(shí)現(xiàn)定時(shí)任務(wù)場(chǎng)景2

安裝

goget-u/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

packagemain

import(

"fmt"

"time"

"/go-co-op/gocron"

funccron1(){

fmt.Println("cron1")

funccron2(){

fmt.Println("cron2")

funcmain(){

timezone,_:=time.LoadLocation("Asia/Shanghai")

s:=gocron.NewScheduler(timezone)

//每秒執(zhí)行一次

s.Every(1).Seconds().Do(func(){

gocron1()

//每秒執(zhí)行一次

s.Every(1).Se