Go的固定時長定時器和周期性時長定時器

Posted on by

我們之前要想在調度裡面實現延時執行，我們可以使用管道阻塞，直到有人往管道裡面寫東西才變通暢，還可以使用sleep來睡覺，但是睡覺的過程，協程啥也幹不瞭也占用資源。所以我們要用到接下來講的定時器，不會像sleep那樣睡的時候也占用資源。

先來看看下面這段代碼： 

package main
​
import (
    "fmt"
    "time"
)
​
func main() {
    timer := time.NewTimer(3 * time.Second)
    fmt.Println("定時器創建完畢！")
    fmt.Println(time.Now())
    //阻塞3秒後才能讀出時間
    x := <- timer.C
    //這個C是一個單向的隻讀管道
    fmt.Println(x)
}

運行結果是這樣的：

定時器創建完畢！
2021-08-24 14:02:28.6664158 +0800 CST m=+0.012997601
2021-08-24 14:02:31.670071 +0800 CST m=+3.016652801

我們可以看到，運行結果和我們要達到的目的基本一致，三秒的定時器創建完畢後，阻塞三秒後才能讀出時間。

我們來看看這個 

x := <- timer.C

根據下面這段代碼可知，這個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()等待規定的一段時間，然後就在返回的管道上發送當前時間。它相當於 NewTimer(d).C。垃圾收集器不會回收底層的 Timer，直到計時器觸發才回收。 如果需要考慮效率，請改用 NewTimer 並在不再需要計時器時調用 Timer.Stop來結束。

當然我們也可以使用下面這種方法，兩種方法都可以： 

x := <- time.NewTimer(3 * time.Second).C

剛才固定時長定時器的就是一個定時炸彈設置為三秒鐘那三秒鐘之後就爆炸，現在我們看看周期性時長定時器吧！ 

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永遠無法讀出數據，
            //一定要讀會導致死鎖.
            ticker.Stop()
            break
        }
    }
    fmt.Println("計時結束")
}

這段代碼的意思是，設置一個周期性時長定時器，然後每一秒從管道內讀一次數據，然後輸出直到i>3，就使用ticker.Stop()將定時器結束，然後停止循環，然後告訴你計時結束。

如果將定時器結束後，你仍然要堅持讀，就會出現下面這種情況！

fatal error: all goroutines are asleep – deadlock!

出現死鎖！所以這裡需要用到break.

到此這篇關於談談Go的固定時長定時器和周期性時長定時器的文章就介紹到這瞭,更多相關Go 定時器 內容請搜索WalkonNet以前的文章或繼續瀏覽下面的相關文章希望大傢以後多多支持WalkonNet！

推薦閱讀：