淺談golang 中time.After釋放的問(wèn)題
在謝大群里看到有同學(xué)在討論time.After泄漏的問(wèn)題,就算時(shí)間到了也不會(huì)釋放,瞬間就驚呆了,忍不住做了試驗(yàn),結(jié)果發(fā)現(xiàn)應(yīng)該沒(méi)有這么的恐怖的,是有泄漏的風(fēng)險(xiǎn)不過(guò)不算是泄漏,
先看API的說(shuō)明:
// 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回收,不過(guò)后面還有條件until the timer fires,說(shuō)明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也是沒(méi)有問(wèn)題的,一樣會(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所說(shuō)的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沒(méi)有釋放而已,會(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的說(shuō)明:
1、GC肯定會(huì)回收time.After的,就在d之后就回收。一般情況下讓系統(tǒng)自己回收就好了。
2、如果有效率問(wèn)題,應(yīng)該使用Timer在不需要時(shí)主動(dòng)Stop。大部分時(shí)候都不用考慮這個(gè)問(wèn)題的。
交作業(yè)。
補(bǔ)充:go語(yǔ)言基于time.After通道超時(shí)設(shè)計(jì)和通道關(guān)閉close
go語(yǔ)言中多個(gè)并發(fā)程序的數(shù)據(jù)同步是采用通道來(lái)傳輸,比如v:=<-chan,從通道里讀取數(shù)據(jù)到v,是一個(gè)阻塞操作。可是如通道里沒(méi)有數(shù)據(jù)寫入,就是chan<-data,這樣寫入通道的操作,在讀操作時(shí)就會(huì)一直阻塞,需要加入一個(gè)超時(shí)機(jī)制來(lái)進(jìn)行判斷。
具體的超時(shí)設(shè)計(jì)是通過(guò)使用select和case語(yǔ)句,類似于switch和case,在每一個(gè)case里進(jìn)行一個(gè)io操作,比如讀或者寫,在最后一個(gè)case里調(diào)用time包里的After方法,可以達(dá)到超時(shí)檢測(cè)效果。參考下面例子1
當(dāng)然,如寫入端在寫入通道結(jié)束后,調(diào)用close(chan)關(guān)閉通道。在讀取端,就會(huì)讀到一個(gè)該通道類型的空值,如是int就是0,如是string就是""空字符串,可以根據(jù)這個(gè)空值來(lái)判斷,或者使用兩個(gè)返回值來(lái)讀取通道:v,br:=<-chan,這里第2個(gè)參數(shù)br是一個(gè)bool變量,表示通道是否關(guān)閉。參考下面例子2
例子1如下:
package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan string, 2)//定義了緩沖長(zhǎng)度2的通道,類型是字符串,可以連續(xù)寫入2次數(shù)據(jù)
go func(c chan string) {
for i := 0; i < 3; i++ {
str := fmt.Sprintf("%d", i)
c <- str
time.Sleep(time.Millisecond * 10)
}
}(ch)
go func(c chan string) {
for i := 10; i < 13; i++ {
str := fmt.Sprintf("%d", i)
c <- str
time.Sleep(time.Millisecond * 10)
}
}(ch)
timelate := 0 //定義超時(shí)次數(shù)
for {
time.Sleep(time.Millisecond * 2000) //每隔2秒讀取下管道
select {
case i := <-ch:
fmt.Println("通道讀取到:", i)
case <-time.After(time.Second * 2): // 等待2秒超時(shí),這里time.After 返回一個(gè)只讀通道,就是當(dāng)前時(shí)間值
timelate++
fmt.Printf("通道接收超時(shí),第%d次\n", timelate)
if timelate > 2 {
goto end
}
}
}
end:
fmt.Println("退出88")
}

例子2如下:
演示了close關(guān)閉通道,使用2個(gè)返回值來(lái)讀取通道,獲取通道關(guān)閉狀態(tài)。
package main
import (
"fmt"
"time"
)
func main() {
ch := make(chan string, 2) //定義了緩沖長(zhǎng)度2的通道,類型是字符串,可以連續(xù)寫入2次數(shù)據(jù)
go func(c chan string) {
for i := 0; i < 3; i++ {
str := fmt.Sprintf("%d", i)
c <- str
time.Sleep(time.Millisecond * 10)
}
}(ch)
go func(c chan string) {
for i := 10; i < 13; i++ {
str := fmt.Sprintf("%d", i)
c <- str
time.Sleep(time.Millisecond * 10)
}
time.Sleep(time.Millisecond * 1000) //專門給這個(gè)協(xié)程加個(gè)1秒的延時(shí),讓它晚退出會(huì),好調(diào)用close關(guān)閉通道。
close(c)
}(ch)
timelate := 0 //定義超時(shí)次數(shù)
for {
time.Sleep(time.Millisecond * 2000) //每隔2秒讀取下管道
select {
case i, br := <-ch: //從通道里讀取2個(gè)返回值,第2個(gè)是通道是否關(guān)閉的bool變量
if !br { //如果是false,表示通道關(guān)閉
fmt.Println("通道關(guān)閉了")
goto end
}
fmt.Println("通道讀取到:", i)
case <-time.After(time.Second * 2): // 等待2秒超時(shí),這里time.After 返回一個(gè)只讀通道,就是當(dāng)前時(shí)間值
timelate++
fmt.Printf("通道接收超時(shí),第%d次\n", timelate)
if timelate > 2 {
goto end
}
}
}
end:
fmt.Println("退出88")
}

對(duì)于例子2來(lái)說(shuō),這里因?yàn)樵谕ǖ缹懭攵擞胏lose關(guān)閉通道了,所以case <-time.After這個(gè)方法的超時(shí)就不起作用了。這里暫且保留著吧。
以上為個(gè)人經(jīng)驗(yàn),希望能給大家一個(gè)參考,也希望大家多多支持腳本之家。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教。
- Go defer與time.sleep的使用與區(qū)別
- 詳解Golang time包中的結(jié)構(gòu)體time.Ticker
- 詳解Golang time包中的time.Duration類型
- 詳解Golang time包中的結(jié)構(gòu)體time.Time
- Go?中?time.After?可能導(dǎo)致的內(nèi)存泄露問(wèn)題解析
- Golang time.Sleep()用法及示例講解
- go?time.Sleep睡眠指定時(shí)間實(shí)例詳解(小時(shí)級(jí)到納秒級(jí))
- 解決Golang time.Parse和time.Format的時(shí)區(qū)問(wèn)題
- go語(yǔ)言time.After()的作用
相關(guān)文章
試了下Golang實(shí)現(xiàn)try catch的方法
雖然在使用Golang的時(shí)候發(fā)現(xiàn)沒(méi)有try catch這種錯(cuò)誤處理機(jī)制但是想一想golang作為一門優(yōu)雅的語(yǔ)言,似乎也是情理之中。那么夠怎么捕獲異常呢,本文就來(lái)介紹一下2021-07-07
Golang編程實(shí)現(xiàn)生成n個(gè)從a到b不重復(fù)隨機(jī)數(shù)的方法
這篇文章主要介紹了Golang編程實(shí)現(xiàn)生成n個(gè)從a到b不重復(fù)隨機(jī)數(shù)的方法,結(jié)合實(shí)例形式分析了Go語(yǔ)言字符串操作及隨機(jī)數(shù)生成的相關(guān)操作技巧,需要的朋友可以參考下2017-01-01
詳解如何在Golang中實(shí)現(xiàn)CORS(跨域)
很多時(shí)候,需要允許Web應(yīng)用程序在不同域之間(跨域)實(shí)現(xiàn)共享資源,本文將簡(jiǎn)介跨域、CORS的概念,以及如何在Golang中如何實(shí)現(xiàn)CORS,文中有詳細(xì)的示例代碼,需要的朋友可以參考下2023-10-10
Go項(xiàng)目在GoLand中導(dǎo)入依賴標(biāo)紅問(wèn)題的解決方案
這篇文章主要介紹了Go項(xiàng)目在GoLand中導(dǎo)入依賴標(biāo)紅問(wèn)題的解決方案,文中通過(guò)代碼示例講解的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2024-06-06
golang sql連接池的實(shí)現(xiàn)方法詳解
database/sql是golang的標(biāo)準(zhǔn)庫(kù)之一,它提供了一系列接口方法,用于訪問(wèn)關(guān)系數(shù)據(jù)庫(kù)。下面這篇文章主要給大家介紹了關(guān)于golang sql連接池用法的相關(guān)資料,文中通過(guò)示例代碼介紹的非常詳細(xì),需要的朋友可以參考借鑒,下面來(lái)一起看看吧2018-09-09
使用IDEA配置GO語(yǔ)言的開(kāi)發(fā)環(huán)境備忘錄
最近在配置idea開(kāi)發(fā)go語(yǔ)言時(shí)碰到很多問(wèn)題,想著很多人都可能會(huì)遇到,所以下面這篇文章主要給大家介紹了關(guān)于使用IDEA配置GO語(yǔ)言的開(kāi)發(fā)環(huán)境,文中通過(guò)圖文介紹的非常詳細(xì),需要的朋友可以參考下2024-05-05

