golang定時器和超時的使用詳解
阿新 • • 發佈:2020-12-22
我就廢話不多說了,大家還是直接看程式碼吧~
func main() { var a chan string a =make(chan string) go sendDataTo(a) go timing() getAchan(10*time.Second,a) } func sendDataTo(a chan string) { for { a <- "我是a通道的資料" time.Sleep(1e9 *3) } } //在一定時間內接收不到a的資料則超時 func getAchan(timeout time.Duration,a chan string) { var after <-chan time.Time loop: after = time.After(timeout) for{ fmt.Println("等待a中的資料,10秒後沒有資料則超時") select { case x :=<- a: fmt.Println(x) goto loop case <-after: fmt.Println("timeout.") return } } } func timing() { //定時器,10秒鐘執行一次 ticker := time.NewTicker(10 * time.Second) for { time := <-ticker.C fmt.Println("定時器====>",time.String()) } }
補充:golang的定時器NewTimer、NewTicker使用
廢話不多說,直接看程式碼
package main import ( "fmt" "sync" "time" ) /** *ticker只要定義完成,從此刻開始計時,不需要任何其他的操作,每隔固定時間都會觸發。 *timer定時器,是到固定時間後會執行一次 *如果timer定時器要每隔間隔的時間執行,實現ticker的效果,使用 func (t *Timer) Reset(d Duration) bool */ func main() { var wg sync.WaitGroup wg.Add(2) //NewTimer 建立一個 Timer,它會在最少過去時間段 d 後到期,向其自身的 C 欄位傳送當時的時間 timer1 := time.NewTimer(2 * time.Second) //NewTicker 返回一個新的 Ticker,該 Ticker 包含一個通道欄位,並會每隔時間段 d 就向該通道傳送當時的時間。它會調 //整時間間隔或者丟棄 tick 資訊以適應反應慢的接收者。如果d <= 0會觸發panic。關閉該 Ticker 可 //以釋放相關資源。 ticker1 := time.NewTicker(2 * time.Second) go func(t *time.Ticker) { defer wg.Done() for { <-t.C fmt.Println("get ticker1",time.Now().Format("2006-01-02 15:04:05")) } }(ticker1) go func(t *time.Timer) { defer wg.Done() for { <-t.C fmt.Println("get timer",time.Now().Format("2006-01-02 15:04:05")) //Reset 使 t 重新開始計時,(本方法返回後再)等待時間段 d 過去後到期。如果呼叫時t //還在等待中會返回真;如果 t已經到期或者被停止了會返回假。 t.Reset(2 * time.Second) } }(timer1) wg.Wait() }
執行結果:
get ticker1 2018-09-07 22:44:29
get timer 2018-09-07 22:44:29
...
額外說明:
time.NewTicker定時觸發執行任務,當下一次執行到來而當前任務還沒有執行結束時,會等待當前任務執行完畢後再執行下一次任務。查閱go官網的文件和經過程式碼驗證。
time.NewTimer和Reset()函式實現定時觸發,Reset()函式可能失敗,經測試。
以上為個人經驗,希望能給大家一個參考,也希望大家多多支援我們。如有錯誤或未考慮完全的地方,望不吝賜教。