Golang中time.After的使用理解與釋放問題
Golang中的time.After的使用理解
關(guān)于在goroutine中使用time.After的理解， 新手在學(xué)習(xí)過程中的“此時此刻”的理解，錯誤還請指正。
先線上代碼：
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定時任務(wù)")
case <-timeout: // 代碼段1
i++
fmt.Println(i, "2s定時輸出")
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點是我們平時遇到的。
首先遇到的問題是：
如上的代碼情況下， 代碼段3處的case 永遠不執(zhí)行， 無論main進程執(zhí)行多久。這是為什么呢？
首先我們分析為啥不執(zhí)行代碼段3， 而是程序一直執(zhí)行的是default. 由此我們判斷：
case <- time.After(time.Second) :
是本次監(jiān)聽動作的超時時間， 意思就說，只有在本次select 操作中會有效， 再次select 又會重新開始計時（從當(dāng)前時間+4秒后）， 但是有default ，那case 超時操作，肯定執(zhí)行不到了。
那么問題就簡單了我們預(yù)先定義了計時操作：
case <- timeout:
在goroutine開始前， 我們記錄了時間，在此時間3s之后進行操作。相當(dāng)于定時任務(wù)， 并且只執(zhí)行一次。 代碼段1和代碼段2 實現(xiàn)的結(jié)果都相同
針對以上問題解決后，我寫了一個小案例：
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("這是定時操作任務(wù) >>>>>")
case dd := <-time.After(time.Second * 3):
fmt.Println(dd, "這是超時*****")
}
fmt.Println("for end")
}
}
執(zhí)行結(jié)果：
要注意的是，雖然執(zhí)行到i == 6時， 堵塞了，并且執(zhí)行了超時操作， 但是下次select 依舊去除的是6
因為通道中已經(jīng)發(fā)送了6,如果未取出，程序堵塞。
GOLANG中time.After釋放的問題
在謝大群里看到有同學(xué)在討論time.After泄漏的問題，就算時間到了也不會釋放，瞬間就驚呆了，忍不住做了試驗，結(jié)果發(fā)現(xiàn)應(yīng)該沒有這么的恐怖的，是有泄漏的風(fēng)險不過不算是泄漏，先看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，這句挺嚇人不會被GC回收，不過后面還有條件until the timer fires，說明fire后是會被回收的，所謂fire就是到時間了，寫個例子證明下壓壓驚：
package main
import "time"
func main() {
for {
<- time.After(10 * time.Nanosecond)
}
}
顯示內(nèi)存穩(wěn)定在5.3MB，CPU為161%，肯定被GC回收了的。當(dāng)然如果放在goroutine也是沒有問題的，一樣會回收：
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)
}
只是資源消耗會多一點，CPU為422%，內(nèi)存占用6.4MB。因此：
Remark: time.After(d)在d時間之后就會fire，然后被GC回收，不會造成資源泄漏的。
那么API所說的If efficieny is a concern, user NewTimer instead and call Timer.Stop是什么意思呢？這是因為一般time.After會在select中使用，如果另外的分支跑得更快，那么timer是不會立馬釋放的(到期后才會釋放)，比如這種：
select {
case time.After(3*time.Second):
return errTimeout
case packet := packetChannel:
// process packet.
}
如果packet非常多，那么總是會走到下面的分支，上面的timer不會立刻釋放而是在3秒后才能釋放，和下面代碼一樣：
package main
import "time"
func main() {
for {
select {
case <-time.After(3 * time.Second):
default:
}
}
}
這個時候，就相當(dāng)于會堆積了3秒的timer沒有釋放而已，會不斷的新建和釋放timer，內(nèi)存會穩(wěn)定在2.8GB，這個當(dāng)然就不是最好的了，可以主動釋放：
package main
import "time"
func main() {
for {
t := time.NewTimer(3*time.Second)
select {
case <- t.C:
default:
t.Stop()
}
}
}
這樣就不會占用2.8GB內(nèi)存了，只有5MB左右。因此，總結(jié)下這個After的說明：
- GC肯定會回收time.After的，就在d之后就回收。一般情況下讓系統(tǒng)自己回收就好了。
- 如果有效率問題，應(yīng)該使用Timer在不需要時主動Stop。大部分時候都不用考慮這個問題的。
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，如果有疑問大家可以留言交流，謝謝大家對腳本之家的支持。
相關(guān)文章
本文詳細講解了Golang中Interface接口的三個特性，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-07-07
本文主要介紹了Go1.18中的泛型編程，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下2021-12-12
這篇文章主要介紹了go-kit組件使用hystrix中間件的操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
Golang實現(xiàn)定時任務(wù)的幾種方法小結(jié)
在 Golang 開發(fā)中,定時任務(wù)是常見的需求,本文將介紹幾種在 Golang 中實現(xiàn)定時任務(wù)的方法,包括 time 包的定時器、ticker,以及第三方庫 cron,并通過示例代碼展示它們的使用方式,需要的朋友可以參考下2024-01-01
golang 實現(xiàn)一個restful微服務(wù)的操作
這篇文章主要介紹了golang 實現(xiàn)一個restful微服務(wù)的操作，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
gin自定義中間件解決requestBody不可重復(fù)讀問題(最新推薦)
這篇文章主要介紹了gin自定義中間件解決requestBody不可重復(fù)讀問題,本文通過示例代碼給大家介紹的非常詳細，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2023-04-04
這篇文章主要介紹了Go語言圖片處理和生成縮略圖的方法,涉及Go語言針對圖片操作的技巧,具有一定參考借鑒價值,需要的朋友可以參考下2015-02-02
Go語言atomic.Value如何不加鎖保證數(shù)據(jù)線程安全？
這篇文章主要介紹了Go語言atomic.Value如何不加鎖保證數(shù)據(jù)線程安全詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進步，早日升職加薪2023-05-05
Golang調(diào)用FFmpeg轉(zhuǎn)換視頻流的實現(xiàn)
本文主要介紹了Golang調(diào)用FFmpeg轉(zhuǎn)換視頻流，文中通過示例代碼介紹的非常詳細，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-02-02
Golang并發(fā)繞不開的重要組件之Channel詳解
Channel是一個提供可接收和發(fā)送特定類型值的用于并發(fā)函數(shù)通信的數(shù)據(jù)類型，也是Golang并發(fā)繞不開的重要組件之一，本文就來和大家深入聊聊Channel的相關(guān)知識吧2023-06-06