協(xié)程泄漏可通過監(jiān)控協(xié)程數(shù)、使用pprof分析堆棧、優(yōu)化退出機制來排查和預(yù)防。首先，通過runtime.numgoroutine()監(jiān)控協(xié)程數(shù)量，若持續(xù)增長則可能存在泄漏；其次，使用pprof查看goroutine堆棧，重點檢查處于chan receive、select或sleep狀態(tài)的協(xié)程；最后，在編碼中避免常見問題，如忘記關(guān)閉channel、select無default分支、循環(huán)中無限啟動協(xié)程，并結(jié)合日志埋點和context控制生命周期，確保協(xié)程能正常退出。
協(xié)程泄漏在 golang 中是一個常見但容易被忽視的問題，尤其在高并發(fā)場景下，如果協(xié)程沒有正確退出，會導(dǎo)致內(nèi)存占用持續(xù)增長、系統(tǒng)性能下降，甚至服務(wù)崩潰。本文直接切入主題，講幾個實用的方法，幫你檢測和預(yù)防協(xié)程泄漏，特別是結(jié)合 runtime 工具進行實戰(zhàn)排查。
如何發(fā)現(xiàn)協(xié)程數(shù)量異常？
最簡單的判斷方式就是監(jiān)控當(dāng)前運行的 goroutine 數(shù)量。Golang 提供了 runtime.NumGoroutine() 函數(shù)，可以實時獲取活躍的協(xié)程數(shù)。你可以把它嵌入到健康檢查接口或者日志中定期輸出：
log.Println("current goroutines:", runtime.NumGoroutine())
如果你觀察到這個數(shù)字一直增長且不回落，那大概率存在協(xié)程泄漏。這時候就需要進一步分析具體是哪個地方創(chuàng)建了大量無法退出的協(xié)程。
立即學(xué)習(xí)“go語言免費學(xué)習(xí)筆記（深入）”；
使用 pprof 查看協(xié)程堆棧信息
Go 自帶的 pprof 工具非常強大，不僅可以用來分析 CPU 和內(nèi)存使用情況，還能查看所有正在運行的協(xié)程堆棧信息。
啟用方法很簡單，在你的服務(wù)中加入以下代碼：
import _ "net/http/pprof" go func() { http.ListenAndServe(":6060", nil) }()
然后訪問 http://localhost:6060/debug/pprof/goroutine?debug=1，可以看到當(dāng)前所有 goroutine 的調(diào)用棧。重點查找那些處于 chan receive, select, 或者 sleep 狀態(tài)但長時間不退出的協(xié)程。
比如你可能會看到類似這樣的內(nèi)容：
goroutine 123 [chan receive]: main.worker()
這說明某個 worker 協(xié)程卡在了 channel 接收操作上，可能是因為沒有關(guān)閉 channel 導(dǎo)致的阻塞。
避免協(xié)程泄漏的幾個關(guān)鍵點
協(xié)程泄漏的根本原因通常是：協(xié)程沒有正常退出路徑。下面是幾個常見的場景和應(yīng)對建議：
- 忘記關(guān)閉 channel：向已關(guān)閉的 channel 發(fā)送數(shù)據(jù)會 panic，但從未關(guān)閉的 channel 讀取會一直阻塞。確保所有寫端都關(guān)閉 channel。
- select 沒有 default 分支或退出機制：如果 select 里只有幾個 case 在等 channel，而這些 channel 又永遠不觸發(fā)，協(xié)程就會卡住。
- 使用 context 控制生命周期：傳入 context 并監(jiān)聽 ctx.Done() 是一種推薦做法，尤其是在處理 HTTP 請求、后臺任務(wù)時。
- 循環(huán)中啟動協(xié)程未控制生命周期：比如在一個 for 循環(huán)里不斷起新協(xié)程但沒有退出機制，很容易積累大量僵尸協(xié)程。
舉個例子：
for { go func() { // 沒有任何退出邏輯 time.Sleep(time.Hour) }() }
這段代碼會在每次循環(huán)中啟動一個協(xié)程，并且每個協(xié)程都睡一小時，但沒有任何機制能終止它們，最終導(dǎo)致協(xié)程爆炸。
實戰(zhàn)小技巧：加 defer 檢查和日志埋點
為了更容易定位問題，可以在協(xié)程開始和結(jié)束的地方加上日志，特別是在關(guān)鍵函數(shù)入口和出口處：
go func() { log.Println("goroutine started") defer func() { log.Println("goroutine exited") }() // 協(xié)程邏輯 }()
這樣即使協(xié)程真的泄露了，也可以通過日志對比“start”和“exit”的數(shù)量差異來快速發(fā)現(xiàn)問題點。
另外，可以考慮封裝一個帶超時的協(xié)程管理器，自動回收長時間未完成的任務(wù)。
基本上就這些。檢測協(xié)程泄漏的關(guān)鍵在于主動監(jiān)控 + 日常編碼習(xí)慣，別讓協(xié)程變成“孤兒”。工具雖然好用，但還是要靠平時寫代碼的時候多留心結(jié)構(gòu)設(shè)計和退出機制。
