我們之前要想在調度里面實現(xiàn)延時執(zhí)行,我們可以使用管道阻塞,直到有人往管道里面寫東西才變通暢,還可以使用sleep來睡覺,但是睡覺的過程,協(xié)程啥也干不了也占用資源。所以我們要用到接下來講的定時器,不會像sleep那樣睡的時候也占用資源。
先來看看下面這段代碼:
package main import ( "fmt" "time" ) func main() { timer := time.NewTimer(3 * time.Second) fmt.Println("定時器創(chuàng)建完畢!") fmt.Println(time.Now()) //阻塞3秒后才能讀出時間 x := - timer.C //這個C是一個單向的只讀管道 fmt.Println(x) }
運行結果是這樣的:
定時器創(chuàng)建完畢!
2021-08-24 14:02:28.6664158 +0800 CST m=+0.012997601
2021-08-24 14:02:31.670071 +0800 CST m=+3.016652801
我們可以看到,運行結果和我們要達到的目的基本一致,三秒的定時器創(chuàng)建完畢后,阻塞三秒后才能讀出時間。
我們來看看這個
x := - timer.C
根據(jù)下面這段代碼可知,這個C是一個單向的只讀管道:
type Timer struct { C -chan Time r runtimeTimer }
如果要描述一個單向的只寫的管道,應該這樣寫:
C chan - Time
但是如果要達到同樣的目的,我們可以使用下面這種更簡單的方式:
func main() { fmt.Println(time.Now()) x := - time.After(3*time.Second) fmt.Println(x) }
使用time.After()等待規(guī)定的一段時間,然后就在返回的管道上發(fā)送當前時間。它相當于 NewTimer(d).C。垃圾收集器不會回收底層的 Timer,直到計時器觸發(fā)才回收。 如果需要考慮效率,請改用 NewTimer 并在不再需要計時器時調用 Timer.Stop來結束。
當然我們也可以使用下面這種方法,兩種方法都可以:
x := - time.NewTimer(3 * time.Second).C
剛才固定時長定時器的就是一個定時炸彈設置為三秒鐘那三秒鐘之后就爆炸,現(xiàn)在我們看看周期性時長定時器吧!
func main() { ticker := time.NewTicker(1 * time.Second) var i int for{ x := - ticker.C fmt.Print("\r",x) i++ if i>3{ //停掉秒表會導致ticker.C永遠無法讀出數(shù)據(jù), //一定要讀會導致死鎖. ticker.Stop() break } } fmt.Println("計時結束") }
這段代碼的意思是,設置一個周期性時長定時器,然后每一秒從管道內讀一次數(shù)據(jù),然后輸出直到i>3,就使用ticker.Stop()將定時器結束,然后停止循環(huán),然后告訴你計時結束。
如果將定時器結束后,你仍然要堅持讀,就會出現(xiàn)下面這種情況!
fatal error: all goroutines are asleep - deadlock!
出現(xiàn)死鎖!所以這里需要用到break.
到此這篇關于談談Go的固定時長定時器和周期性時長定時器的文章就介紹到這了,更多相關Go 定時器 內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!