我就廢話不多說(shuō)了,大家還是直接看代碼吧~
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通道的數(shù)據(jù)"
time.Sleep(1e9 *3)
}
}
//在一定時(shí)間內(nèi)接收不到a的數(shù)據(jù)則超時(shí)
func getAchan(timeout time.Duration, a chan string) {
var after -chan time.Time
loop:
after = time.After(timeout)
for{
fmt.Println("等待a中的數(shù)據(jù),10秒后沒有數(shù)據(jù)則超時(shí)")
select {
case x :=- a:
fmt.Println(x)
goto loop
case -after:
fmt.Println("timeout.")
return
}
}
}
func timing() {
//定時(shí)器,10秒鐘執(zhí)行一次
ticker := time.NewTicker(10 * time.Second)
for {
time := -ticker.C
fmt.Println("定時(shí)器====>",time.String())
}
}
補(bǔ)充:golang的定時(shí)器NewTimer、NewTicker使用
廢話不多說(shuō),直接看代碼
package main
import (
"fmt"
"sync"
"time"
)
/**
*ticker只要定義完成,從此刻開始計(jì)時(shí),不需要任何其他的操作,每隔固定時(shí)間都會(huì)觸發(fā)。
*timer定時(shí)器,是到固定時(shí)間后會(huì)執(zhí)行一次
*如果timer定時(shí)器要每隔間隔的時(shí)間執(zhí)行,實(shí)現(xiàn)ticker的效果,使用 func (t *Timer) Reset(d Duration) bool
*/
func main() {
var wg sync.WaitGroup
wg.Add(2)
//NewTimer 創(chuàng)建一個(gè) Timer,它會(huì)在最少過去時(shí)間段 d 后到期,向其自身的 C 字段發(fā)送當(dāng)時(shí)的時(shí)間
timer1 := time.NewTimer(2 * time.Second)
//NewTicker 返回一個(gè)新的 Ticker,該 Ticker 包含一個(gè)通道字段,并會(huì)每隔時(shí)間段 d 就向該通道發(fā)送當(dāng)時(shí)的時(shí)間。它會(huì)調(diào)
//整時(shí)間間隔或者丟棄 tick 信息以適應(yīng)反應(yīng)慢的接收者。如果d = 0會(huì)觸發(fā)panic。關(guān)閉該 Ticker 可
//以釋放相關(guān)資源。
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 重新開始計(jì)時(shí),(本方法返回后再)等待時(shí)間段 d 過去后到期。如果調(diào)用時(shí)t
//還在等待中會(huì)返回真;如果 t已經(jīng)到期或者被停止了會(huì)返回假。
t.Reset(2 * time.Second)
}
}(timer1)
wg.Wait()
}
運(yùn)行結(jié)果:
get ticker1 2018-09-07 22:44:29
get timer 2018-09-07 22:44:29
...
額外說(shuō)明:
time.NewTicker定時(shí)觸發(fā)執(zhí)行任務(wù),當(dāng)下一次執(zhí)行到來(lái)而當(dāng)前任務(wù)還沒有執(zhí)行結(jié)束時(shí),會(huì)等待當(dāng)前任務(wù)執(zhí)行完畢后再執(zhí)行下一次任務(wù)。查閱go官網(wǎng)的文檔和經(jīng)過代碼驗(yàn)證。
time.NewTimer和Reset()函數(shù)實(shí)現(xiàn)定時(shí)觸發(fā),Reset()函數(shù)可能失敗,經(jīng)測(cè)試。
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。
您可能感興趣的文章:- Golang定時(shí)器的2種實(shí)現(xiàn)方法與區(qū)別
- Golang 定時(shí)器(Timer 和 Ticker),這篇文章就夠了
- Golang中定時(shí)器的陷阱詳解
- 用golang實(shí)現(xiàn)一個(gè)定時(shí)器任務(wù)隊(duì)列實(shí)例
- golang中定時(shí)器cpu使用率高的現(xiàn)象詳析
- golang time包下定時(shí)器的實(shí)現(xiàn)方法
- Golang 定時(shí)器的終止與重置實(shí)現(xiàn)