主頁 > 知識(shí)庫 > Golang中time.After的使用理解與釋放問題

Golang中time.After的使用理解與釋放問題

熱門標(biāo)簽:高德地圖標(biāo)注口訣 中國地圖標(biāo)注省會(huì)高清 南通如皋申請開通400電話 學(xué)海導(dǎo)航地圖標(biāo)注 西部云谷一期地圖標(biāo)注 浙江高速公路地圖標(biāo)注 廣州呼叫中心外呼系統(tǒng) 江西轉(zhuǎn)化率高的羿智云外呼系統(tǒng) 地圖標(biāo)注的汽車標(biāo)

Golang中的time.After的使用理解

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

先線上代碼:

package main

import (
 "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í)行, 無論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í)行不到了。

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

                case - timeout:

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

針對以上問題解決后,我寫了一個(gè)小案例:

package main

import (
 "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 main

import "time"

func main() {
 for {
  - time.After(10 * time.Nanosecond)
 }
}

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

package main

import "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 main

import "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 main

import "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é)

以上就是這篇文章的全部內(nèi)容了,希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,如果有疑問大家可以留言交流,謝謝大家對腳本之家的支持。

您可能感興趣的文章:
  • Go語言利用time.After實(shí)現(xiàn)超時(shí)控制的方法詳解

標(biāo)簽:貴州 許昌 東營 吐魯番 常州 保定 曲靖 德宏

巨人網(wǎng)絡(luò)通訊聲明:本文標(biāo)題《Golang中time.After的使用理解與釋放問題》,本文關(guān)鍵詞  Golang,中,time.After,的,使用,;如發(fā)現(xiàn)本文內(nèi)容存在版權(quán)問題,煩請?zhí)峁┫嚓P(guān)信息告之我們,我們將及時(shí)溝通與處理。本站內(nèi)容系統(tǒng)采集于網(wǎng)絡(luò),涉及言論、版權(quán)與本站無關(guān)。
  • 相關(guān)文章
  • 下面列出與本文章《Golang中time.After的使用理解與釋放問題》相關(guān)的同類信息!
  • 本頁收集關(guān)于Golang中time.After的使用理解與釋放問題的相關(guān)信息資訊供網(wǎng)民參考!
  • 推薦文章