我就廢話不多說了,大家還是直接看代碼吧~
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()函數可能失敗,經測試。
以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。
您可能感興趣的文章:- Golang定時器的2種實現方法與區別
- Golang 定時器(Timer 和 Ticker),這篇文章就夠了
- Golang中定時器的陷阱詳解
- 用golang實現一個定時器任務隊列實例
- golang中定時器cpu使用率高的現象詳析
- golang time包下定時器的實現方法
- Golang 定時器的終止與重置實現