Golang中的time.After的使用理解

關(guān)于在goroutine中使用time.After的理解， 新手在學(xué)習(xí)過程中的“此時(shí)此刻”的理解，錯(cuò)誤還請(qǐng)指正。

先線上代碼：

package mainimport ( "fmt" "time")func main() { //closeChannel() c := make(chan int) timeout := time.After(time.Second * 2) // t1 := time.NewTimer(time.Second * 3) // 效果相同 只執(zhí)行一次 var i int go func() { for { select { case <-c: fmt.Println("channel sign") return case <-t1.C: // 代碼段2 fmt.Println("3s定時(shí)任務(wù)") case <-timeout: // 代碼段1 i++ fmt.Println(i, "2s定時(shí)輸出") case <-time.After(time.Second * 4): // 代碼段3 fmt.Println("4s timeout。。。。")  default:    // 代碼段4 fmt.Println("default") time.Sleep(time.Second * 1) } } }() time.Sleep(time.Second * 6) close(c) time.Sleep(time.Second * 2) fmt.Println("main退出")}

主要有以上4點(diǎn)是我們平時(shí)遇到的。

首先遇到的問題是：

              如上的代碼情況下， 代碼段3處的case 永遠(yuǎn)不執(zhí)行， 無(wú)論main進(jìn)程執(zhí)行多久。這是為什么呢？

首先我們分析為啥不執(zhí)行代碼段3， 而是程序一直執(zhí)行的是default.  由此我們判斷：

                case <- time.After(time.Second)  :  

                是本次監(jiān)聽動(dòng)作的超時(shí)時(shí)間， 意思就說，只有在本次select 操作中會(huì)有效， 再次select 又會(huì)重新開始計(jì)時(shí)（從當(dāng)前時(shí)間+4秒后）， 但是有default ，那case 超時(shí)操作，肯定執(zhí)行不到了。

                那么問題就簡(jiǎn)單了我們預(yù)先定義了計(jì)時(shí)操作：

                case <- timeout:

                    在goroutine開始前， 我們記錄了時(shí)間，在此時(shí)間3s之后進(jìn)行操作。相當(dāng)于定時(shí)任務(wù)， 并且只執(zhí)行一次。 代碼段1和代碼段2 實(shí)現(xiàn)的結(jié)果都相同

針對(duì)以上問題解決后，我寫了一個(gè)小案例：

package mainimport ( "fmt" "time")//發(fā)送者func sender(c chan int) { for i := 0; i < 100; i++ { c <- i if i >= 5 { time.Sleep(time.Second * 7) } else { time.Sleep(time.Second) } }}func main() { c := make(chan int) go sender(c) timeout := time.After(time.Second * 3) for { select { case d := <-c: fmt.Println(d) case <-timeout: fmt.Println("這是定時(shí)操作任務(wù) >>>>>") case dd := <-time.After(time.Second * 3): fmt.Println(dd, "這是超時(shí)*****") } fmt.Println("for end") }}

執(zhí)行結(jié)果：

要注意的是，雖然執(zhí)行到i == 6時(shí)， 堵塞了，并且執(zhí)行了超時(shí)操作， 但是下次select 依舊去除的是6

因?yàn)橥ǖ乐幸呀?jīng)發(fā)送了6,如果未取出，程序堵塞。

GOLANG中time.After釋放的問題

在謝大群里看到有同學(xué)在討論time.After泄漏的問題，就算時(shí)間到了也不會(huì)釋放，瞬間就驚呆了，忍不住做了試驗(yàn)，結(jié)果發(fā)現(xiàn)應(yīng)該沒有這么的恐怖的，是有泄漏的風(fēng)險(xiǎn)不過不算是泄漏，先看API的說明：

// After waits for the duration to elapse and then sends the current time// on the returned channel.// It is equivalent to NewTimer(d).C.// The underlying Timer is not recovered by the garbage collector// until the timer fires. If efficiency is a concern, use NewTimer// instead and call Timer.Stop if the timer is no longer needed.func After(d Duration) <-chan Time { return NewTimer(d).C}

提到了一句The underlying Timer is not recovered by the garbage collector，這句挺嚇人不會(huì)被GC回收，不過后面還有條件until the timer fires，說明fire后是會(huì)被回收的，所謂fire就是到時(shí)間了，寫個(gè)例子證明下壓壓驚：

package mainimport "time"func main() { for {  <- time.After(10 * time.Nanosecond) }}

顯示內(nèi)存穩(wěn)定在5.3MB，CPU為161%，肯定被GC回收了的。當(dāng)然如果放在goroutine也是沒有問題的，一樣會(huì)回收：

package mainimport "time"func main() { for i := 0; i < 100; i++ {  go func(){   for {    <- time.After(10 * time.Nanosecond)   }  }() } time.Sleep(1 * time.Hour)}

只是資源消耗會(huì)多一點(diǎn)，CPU為422%，內(nèi)存占用6.4MB。因此：

Remark: time.After(d)在d時(shí)間之后就會(huì)fire，然后被GC回收，不會(huì)造成資源泄漏的。

那么API所說的If efficieny is a concern, user NewTimer instead and call Timer.Stop是什么意思呢？這是因?yàn)橐话鉻ime.After會(huì)在select中使用，如果另外的分支跑得更快，那么timer是不會(huì)立馬釋放的(到期后才會(huì)釋放)，比如這種：

select { case time.After(3*time.Second):  return errTimeout case packet := packetChannel:  // process packet.}

如果packet非常多，那么總是會(huì)走到下面的分支，上面的timer不會(huì)立刻釋放而是在3秒后才能釋放，和下面代碼一樣：

package mainimport "time"func main() { for {  select {  case <-time.After(3 * time.Second):  default:  } }}

這個(gè)時(shí)候，就相當(dāng)于會(huì)堆積了3秒的timer沒有釋放而已，會(huì)不斷的新建和釋放timer，內(nèi)存會(huì)穩(wěn)定在2.8GB，這個(gè)當(dāng)然就不是最好的了，可以主動(dòng)釋放：

package mainimport "time"func main() { for {  t := time.NewTimer(3*time.Second)  select {  case <- t.C:  default:   t.Stop()  } }}

這樣就不會(huì)占用2.8GB內(nèi)存了，只有5MB左右。因此，總結(jié)下這個(gè)After的說明：

• GC肯定會(huì)回收time.After的，就在d之后就回收。一般情況下讓系統(tǒng)自己回收就好了。
• 如果有效率問題，應(yīng)該使用Timer在不需要時(shí)主動(dòng)Stop。大部分時(shí)候都不用考慮這個(gè)問題的。

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值，如果有疑問大家可以留言交流，謝謝大家對(duì)VEVB武林網(wǎng)的支持。