快捷導(dǎo)航

Golang cron 定時(shí)器和定時(shí)任務(wù)的使用場(chǎng)景

更新時(shí)間：2022年09月30日 14:23:43 作者：beyond阿亮

Ticker是一個(gè)周期觸發(fā)定時(shí)的計(jì)時(shí)器，它會(huì)按照一個(gè)時(shí)間間隔往channel發(fā)送系統(tǒng)當(dāng)前時(shí)間，而channel的接收者可以以固定的時(shí)間間隔從channel中讀取事件，這篇文章主要介紹了Golang cron 定時(shí)器和定時(shí)任務(wù),需要的朋友可以參考下

Golang cron 定時(shí)器和定時(shí)任務(wù)

Golang中time包有兩個(gè)定時(shí)器，分別為 ticker 和 timer。兩者都可以實(shí)現(xiàn)定時(shí)功能，但各自都有自己的使用場(chǎng)景。

timer和ticker的區(qū)別

ticker定時(shí)器表示每隔一段時(shí)間就執(zhí)行一次，一般可執(zhí)行多次。
timer定時(shí)器表示在一段時(shí)間后執(zhí)行，默認(rèn)情況下只執(zhí)行一次，如果想再次執(zhí)行的話(huà)，每次都需要調(diào)用 time.Reset() 方法，此時(shí)效果類(lèi)似ticker定時(shí)器。同時(shí)也可以調(diào)用 Stop() 方法取消定時(shí)器
timer定時(shí)器比ticker定時(shí)器多一個(gè) Reset() 方法，兩者都有 Stop() 方法，表示停止定時(shí)器,底層都調(diào)用了stopTimer() 函數(shù)。

Timer

Timer是一個(gè)定時(shí)器。代表未來(lái)的一個(gè)單一事件，你可以告訴timer你要等待多長(zhǎng)時(shí)間。

package main

import (
    "fmt"
    "time"
)

func main() {

    //設(shè)置定時(shí)器為3秒
    timer := time.NewTimer(3 * time.Second)
    fmt.Println("當(dāng)前時(shí)間為:", time.Now())

    t := <-timer.C //從定時(shí)器拿數(shù)據(jù)
    fmt.Println("當(dāng)前時(shí)間為:", t)
}

Ticker

Ticker是一個(gè)周期觸發(fā)定時(shí)的計(jì)時(shí)器，它會(huì)按照一個(gè)時(shí)間間隔往channel發(fā)送系統(tǒng)當(dāng)前時(shí)間，而channel的接收者可以以固定的時(shí)間間隔從channel中讀取事件。

Ticker是一個(gè)定時(shí)觸發(fā)的計(jì)時(shí)器，
它會(huì)以一個(gè)間隔(interval)往channel發(fā)送一個(gè)事件(當(dāng)前時(shí)間)，
而channel的接收者可以以固定的時(shí)間間隔從channel中讀取事件。

package main

import (
    "fmt"
    "time"
)

func main() {

    //創(chuàng)建一個(gè)周期性的定時(shí)器
    ticker := time.NewTicker(3 * time.Second)
    fmt.Println("當(dāng)前時(shí)間為:", time.Now())

    go func() {
        for {

            //從定時(shí)器中獲取數(shù)據(jù)
            t := <-ticker.C
            fmt.Println("當(dāng)前時(shí)間為:", t)

        }
    }()

    for {
        time.Sleep(time.Second * 1)
    }
}

cron 定時(shí)任務(wù)

package main

import (
	"github.com/robfig/cron"
	"log"
	"time"
)

func main() {
	//cron1()

	//cron2()

	cron3()

	select {
	}
}

func cron1()  {
	log.Println("Starting...")
	c := cron.New()
	c.AddFunc("* * * * * *", func() {
		log.Println("Run models.CleanAllTag...")
	})
	c.AddFunc("* * * * * *", func() {
		log.Println("Run models.CleanAllArticle...")
	})

	c.Start()

	t1 := time.NewTimer(time.Second * 10)
	for {
	select {
	case <-t1.C:
	    t1.Reset(time.Second * 10)
	}
	}
}

func cron2()  {
	log.Println("Starting...")
	c := cron.New()  // 新建一個(gè)定時(shí)任務(wù)對(duì)象
	c.AddFunc("* * * * * *", func() {
		log.Println("hello world")
	})  // 給對(duì)象增加定時(shí)任務(wù)
	c.Start()
	//select {
	//}
	time.Sleep(10 * time.Second)
	c.Stop()
}

func cron3()  {
	log.Println("Starting...")

	c := cron.New()
	h := Hello{"I Love You!"}
	// 添加定時(shí)任務(wù)
	c.AddJob("*/2 * * * * *", h)
	// 添加定時(shí)任務(wù) 5秒執(zhí)行一次
	c.AddFunc("*/5 * * * * *", func() {
		log.Println("hello word")
	})

	s, err := cron.Parse("*/3 * * * * *")
	if err != nil {
		log.Println("Parse error")
	}
	h2 := Hello{"I Hate You!"}
	c.Schedule(s, h2)
	// 其中任務(wù)
	c.Start()
	// 關(guān)閉任務(wù)
	defer c.Stop()
}

type Hello struct {
	Str string
}

func(h Hello) Run() {
	log.Println(h.Str)
}

參考鏈接:

https://blog.haohtml.com/archives/19859
https://studygolang.com/articles/17624
https://www.jianshu.com/p/fd3dda663953
https://blog.51cto.com/u_13914991/2294357
https://www.cnblogs.com/yinzhengjie/p/12244385.html
http://t.zoukankan.com/yinzhengjie-p-12245289.html
https://blog.51cto.com/u_13914991/2294357

到此這篇關(guān)于Golang cron 定時(shí)器和定時(shí)任務(wù)的文章就介紹到這了,更多相關(guān)Golang cron 定時(shí)任務(wù)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: