? 例子：未關(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)鍵問題！

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

? 問題分析：

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

注意：即使 main 結(jié)束，程序會(huì)直接退出，但在實(shí)際服務(wù)中（如 Web 服務(wù)），這類 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è)常見泄漏場(chǎng)景：goroutine 等待向無接收者的 channel 發(fā)送

package main

import "time"

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

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

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

? 問題：

• 向一個(gè)無緩沖 channel 發(fā)送數(shù)據(jù)，但沒有其他 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
   }

   然后訪問 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é)常見導(dǎo)致泄漏的原因：

   • ? 忘記 close channel，導(dǎo)致 range 或 永久阻塞
   • ? 啟動(dòng) goroutine 發(fā)送數(shù)據(jù)，但沒有接收者
   • ? 使用 select 但某些 case 永遠(yuǎn)無法觸發(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ù)量變化

   ---

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

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