? 例子：未關(guān)閉的channel 導(dǎo)致接收goroutine 阻塞

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    // 啟動(dòng)一個(gè)goroutine 接收數(shù)據(jù)go func() {
        for value := range ch {
            fmt.Println("Received:", value)
        }
    }()

    // 發(fā)送幾個(gè)值ch <- 1
    ch <- 2

    // 忘記close(ch) —— 關(guān)鍵問(wèn)題！

    // 主協(xié)程休眠，觀察洩漏time.Sleep(5 * time.Second)
    fmt.Println("Main done")
}

? 問(wèn)題分析：

• for range ch會(huì)一直等待channel 中的新數(shù)據(jù)。
• 主協(xié)程沒(méi)有close(ch) ，接收goroutine 永遠(yuǎn)不會(huì)退出。
• 即使main函數(shù)結(jié)束，這個(gè)goroutine 仍處?kù)蹲枞麪顟B(tài)，造成goroutine 洩漏。

注意：即使main結(jié)束，程序會(huì)直接退出，但在實(shí)際服務(wù)中（如Web 服務(wù)），這類(lèi)goroutine 會(huì)累積。

? 修復(fù)方法：及時(shí)關(guān)閉channel

 package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)

    go func() {
        for value := range ch {
            fmt.Println("Received:", value)
        }
        fmt.Println("Receiver exiting...")
    }()

    ch <- 1
    ch <- 2
    close(ch) // 正確關(guān)閉channel，使range 結(jié)束time.Sleep(1 * time.Second) // 等待receiver 退出fmt.Println("Main done")
}

? 輸出：

 Received: 1
Received: 2
Receiver exiting...
Main done

此時(shí)，goroutine 能正常退出，不會(huì)洩漏。

? 另一個(gè)常見(jiàn)洩漏場(chǎng)景：goroutine 等待向無(wú)接收者的channel 發(fā)送

package main

import "time"

func main() {
    ch := make(chan int)

    go func() {
        ch <- 100 // 阻塞：沒(méi)有接收者}()

    time.Sleep(2 * time.Second)
    // 沒(méi)有接收者，goroutine 永遠(yuǎn)阻塞}

? 問(wèn)題：

• 向一個(gè)無(wú)緩衝channel 發(fā)送數(shù)據(jù)，但沒(méi)有其他goroutine 接收。
• 發(fā)送操作<- ch是同步阻塞的，該goroutine 將永遠(yuǎn)卡住。

? 修復(fù)方法：

確保有接收者，或使用帶緩衝的channel 超時(shí)機(jī)制。

 go func() {
    select {
    case ch <- 100:
        fmt.Println("Sent successfully")
    case <-time.After(1 * time.Second):
        fmt.Println("Send timeout, avoid blocking")
    }
}()

? 如何檢測(cè)Goroutine 洩漏？

1. 使用pprof工具：

    import _ "net/http/pprof"
   import "net/http"
   
   func main() {
       go func() {
           http.ListenAndServe("localhost:6060", nil)
       }()
       // ... your code
   }

   然後訪(fǎng)問(wèn)http://localhost:6060/debug/pprof/goroutine查看當(dāng)前goroutine 數(shù)量。

2. 測(cè)試時(shí)使用runtime.NumGoroutine() ：

    fmt.Println("Goroutines:", runtime.NumGoroutine())

   在關(guān)鍵路徑前後對(duì)比數(shù)量，判斷是否增長(zhǎng)異常。

   ---

   總結(jié)常見(jiàn)導(dǎo)致洩漏的原因：

   • ? 忘記close channel，導(dǎo)致range或永久阻塞
   • ? 啟動(dòng)goroutine 發(fā)送數(shù)據(jù)，但沒(méi)有接收者
   • ? 使用select但某些case 永遠(yuǎn)無(wú)法觸發(fā)
   • ? goroutine 等待一個(gè)永遠(yuǎn)不會(huì)發(fā)生的事件（如context 未取消）

   ---

   最佳實(shí)踐建議：

   • 使用context.Context控制goroutine 生命週期
   • 確保每個(gè)啟動(dòng)的goroutine 都有明確的退出路徑
   • 對(duì)channel 操作要配對(duì)：有發(fā)送就要有接收，有range 就要close
   • 在測(cè)試中監(jiān)控goroutine 數(shù)量變化

   ---

   基本上就這些常見(jiàn)情況。 goroutine 洩漏不總是立刻顯現(xiàn)，但在長(zhǎng)期運(yùn)行的服務(wù)中危害很大，需要特別小心。

   以上是Goroutine洩漏示例的詳細(xì)內(nèi)容。更多資訊請(qǐng)關(guān)注PHP中文網(wǎng)其他相關(guān)文章！