好湿?好紧?好多水好爽自慰,久久久噜久噜久久综合,成人做爰A片免费看黄冈,机机对机机30分钟无遮挡

主頁 > 知識庫 > 淺談golang 中time.After釋放的問題

淺談golang 中time.After釋放的問題

熱門標簽:阿克蘇地圖標注 涿州代理外呼系統 外呼系統顯本地手機號 外呼系統用什么卡 壽光微信地圖標注 評價高的400電話辦理 excel地圖標注分布數據 百度地圖標注后傳給手機 電話機器人軟件免費

在謝大群里看到有同學在討論time.After泄漏的問題,就算時間到了也不會釋放,瞬間就驚呆了,忍不住做了試驗,結果發現應該沒有這么的恐怖的,是有泄漏的風險不過不算是泄漏,

先看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)
    }
}

顯示內存穩定在5.3MB,CPU為161%,肯定被GC回收了的。

當然如果放在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%,內存占用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:
        }
    }
}

這個時候,就相當于會堆積了3秒的timer沒有釋放而已,會不斷的新建和釋放timer,內存會穩定在2.8GB,

這個當然就不是最好的了,可以主動釋放:

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

這樣就不會占用2.8GB內存了,只有5MB左右。因此,總結下這個After的說明:

1、GC肯定會回收time.After的,就在d之后就回收。一般情況下讓系統自己回收就好了。

2、如果有效率問題,應該使用Timer在不需要時主動Stop。大部分時候都不用考慮這個問題的。

交作業。

補充:go語言基于time.After通道超時設計和通道關閉close

go語言中多個并發程序的數據同步是采用通道來傳輸,比如v:=-chan,從通道里讀取數據到v,是一個阻塞操作??墒侨缤ǖ览餂]有數據寫入,就是chan-data,這樣寫入通道的操作,在讀操作時就會一直阻塞,需要加入一個超時機制來進行判斷。

具體的超時設計是通過使用select和case語句,類似于switch和case,在每一個case里進行一個io操作,比如讀或者寫,在最后一個case里調用time包里的After方法,可以達到超時檢測效果。參考下面例子1

當然,如寫入端在寫入通道結束后,調用close(chan)關閉通道。在讀取端,就會讀到一個該通道類型的空值,如是int就是0,如是string就是""空字符串,可以根據這個空值來判斷,或者使用兩個返回值來讀取通道:v,br:=-chan,這里第2個參數br是一個bool變量,表示通道是否關閉。參考下面例子2

例子1如下:

package main 
import (
	"fmt"
	"time"
)
 
func main() {
	ch := make(chan string, 2)//定義了緩沖長度2的通道,類型是字符串,可以連續寫入2次數據
	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 //定義超時次數
	for {
		time.Sleep(time.Millisecond * 2000) //每隔2秒讀取下管道
		select {
		case i := -ch:
			fmt.Println("通道讀取到:", i)
		case -time.After(time.Second * 2): // 等待2秒超時,這里time.After 返回一個只讀通道,就是當前時間值
			timelate++
			fmt.Printf("通道接收超時,第%d次\n", timelate)
			if timelate > 2 {
				goto end
			}
		}
	}
end:
	fmt.Println("退出88")
}

例子2如下:

演示了close關閉通道,使用2個返回值來讀取通道,獲取通道關閉狀態。

package main 
import (
	"fmt"
	"time"
)
 
func main() {
	ch := make(chan string, 2) //定義了緩沖長度2的通道,類型是字符串,可以連續寫入2次數據
	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) //專門給這個協程加個1秒的延時,讓它晚退出會,好調用close關閉通道。
		close(c)
	}(ch)
	timelate := 0 //定義超時次數
	for {
		time.Sleep(time.Millisecond * 2000) //每隔2秒讀取下管道
		select {
		case i, br := -ch: //從通道里讀取2個返回值,第2個是通道是否關閉的bool變量
			if !br { //如果是false,表示通道關閉
				fmt.Println("通道關閉了")
				goto end
			}
			fmt.Println("通道讀取到:", i)
		case -time.After(time.Second * 2): // 等待2秒超時,這里time.After 返回一個只讀通道,就是當前時間值
			timelate++
			fmt.Printf("通道接收超時,第%d次\n", timelate)
			if timelate > 2 {
				goto end
			}
		}
	}
end:
	fmt.Println("退出88")
}

對于例子2來說,這里因為在通道寫入端用close關閉通道了,所以case -time.After這個方法的超時就不起作用了。這里暫且保留著吧。

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。

您可能感興趣的文章:
  • Golang開發動態庫的實現
  • golang實踐-第三方包為私有庫的配置方案
  • 完美解決golang go get私有倉庫的問題
  • golang gopm get -g -v 無法獲取第三方庫的解決方案
  • Golang: 內建容器的用法
  • golang 定時任務方面time.Sleep和time.Tick的優劣對比分析
  • golang日志包logger的用法詳解
  • Golang如何調用windows下的dll動態庫中的函數

標簽:雞西 重慶 欽州 蘭州 吐魯番 銅川 汕頭 梅河口

巨人網絡通訊聲明:本文標題《淺談golang 中time.After釋放的問題》,本文關鍵詞  淺談,golang,中,time.After,釋放,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《淺談golang 中time.After釋放的問題》相關的同類信息!
  • 本頁收集關于淺談golang 中time.After釋放的問題的相關信息資訊供網民參考!
  • 推薦文章
    主站蜘蛛池模板: 玖操在线| 男人操男人视频| 精品人妻无码一区二区三区电影| 欧美黑人性猛交╳XX╳动态图| 色干网| 欧美激情精品久久久久久免费印度| 欧美熟妇A片在线观看麻豆| 一级生活黄色片| 涩涩在线播放视频视频| 被邻居c哭调教双性怀孕了小说| 王语嫣含精肉臀迎合娇吟视频| 午夜免费影院| 台湾昊梦梦免费无删减| 亚洲国产精品第一区二区三区| 变天就操| 最近更新中文字幕免费大全| 久久聊| 久久精品国产亚洲AV天北条麻妃| 小小爱奴| 欧美壮熊| 冰上的尤里未删减版动漫资源| 成人欧美AV精品 9 2 1 5肥臀APP| 有码 自拍 日韩 中文 在线 | 两口子交换真实刺激高潮| 爽死你个放荡小婬妇视频播放| 夜夜爱夜夜爽夜夜做夜夜欢| 天天操夜夜操狠狠操| 国产一区二区三区在线观看免费| 中文黑人寄宿ntr内裤遮不住| 日韩精品无码久久久久成人| 一本色道久久综合亚洲精品图片| 国产动漫必看30部| 裸体无码婬片A片AAA毛片裸体| 情圣电影| 男女搞鸡app| 情侣奴跪下用嘴伺候主人| 秋霞电影网院午夜伦不卡A片| 国模孕妇季玥大胆私拍套装| 亚洲一区图片| 天天看片天天操| 被皇帝调教成禁脔h虐|