golang定時任務詳解

摘要： 在程式中經常需要按照指定的週期（以毫秒計）來呼叫函式或計算表示式，也即實現定時任務，使用time包中Tick和Sleep可以輕鬆實現定時任務 使用Tick每隔100毫秒列印“Hello TigerwolfC” for range time.Tick(time.Millis...

在程式中經常需要按照指定的週期（以毫秒計）來呼叫函式或計算表示式，也即實現定時任務，使用time包中Tick和Sleep可以輕鬆實現定時任務

使用Tick每隔100毫秒列印“Hello TigerwolfC”

for range time.Tick(time.Millisecond*100){
fmt.Println("Hello TigerwolfC") 
}

每隔100毫秒列印 “Hello TigerwolfC”，也可以使用 time.Sleep()

for{
time.Sleep(time.Millisecond* 100)
fmt.Println("Hello TigerwolfC")
}

每隔5秒執行f()函式

c := time.Tick(5 * time.Second)
for {
<- c
go f()
}

也可使用定時器，例如

package main

import (
"fmt"
"time"
)

func main() {
var ch chan int
//定時任務
ticker := time.NewTicker(time.Second * 5)
go func() {
for range ticker.C {
fmt.Println(time.Now().Format("2006-01-02 15:04:05"))
}
ch <- 1
}()
<-ch
}

輸出結果：

2018-12-08 08:30:472018-12-08 08:30:522018-12-08 08:30:572018-12-08 08:31:022018-12-08 08:31:072018-12-08 08:31:12……

如下例子，使用定時器每隔12小時從MySQL複製使用者資訊到Redis資料庫

func CopyUserInfo() {
for {
rows, err := MysqlClient.Query("SELECT name,mail,department,title FROM UsersInfo")
if err != nil {
log4go.Info("query mysqlDB fail")
return
}

userInfos := make(map[int]models.UserInfo)
userInfo := models.UserInfo{}
i := 0
for rows.Next() {
rows.Scan(&userInfo.Name, &userInfo.Mail, &userInfo.Department, &userInfo.Title)
userInfos[i] = userInfo
i++
}

SetUserNameMail(userInfos)//save userInfo into Redis
SetUserDisplaynameMail(userInfos) //save userInfo into Redis
fmt.Println("userinfo copy to redis successfully")
ticker := time.NewTicker(time.Hour * 12)
<-ticker.C
}

}

啟動的時候執行一次，以後每天晚上12點執行

func startTimer(f func()) {
go func() {
for {
f()
now := time.Now()
// 計算下一個零點
next := now.Add(time.Hour * 24)
next = time.Date(next.Year(), next.Month(), next.Day(), 0,0,0,0,next.Location())
t := time.NewTimer(next.Sub(now))
<-t.C
}
}()
}

如有不對歡迎指正，相互學習，共同進步。