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

// 每隔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 * * ?

* * * * * for i in $(seq 1 11); do echo test >> /etc/demo/demo.txt; sleep 1; done

package main

import (
	"fmt"
	"time"
)

func main() {
	t := time.NewTimer(1 * time.Second)
	<-t.C
	fmt.Println("1 s 時間到")

}

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 {

	}
}

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 {
	}
}

package main

import (
	"fmt"
	"time"
)

func main() {

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

	for range ticker.C {
		fmt.Println("執行的業務邏輯")
	}
}

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()

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()
}