面试题：Go并发程序中Goroutine泄露调试技巧

检测并定位泄露的Goroutine方法和工具

pprof工具：
- 使用方式：在Go程序中导入net/http/pprof包，并在代码中添加HTTP服务器相关代码来暴露pprof数据，例如：

package main

import (
    "net/http"
    _ "net/http/pprof"
)

func main() {
    go func() {
        http.ListenAndServe(":6060", nil)
    }()
    // 主业务逻辑
}

分析：通过浏览器访问http://localhost:6060/debug/pprof/goroutine，可以看到当前运行的所有Goroutine的堆栈信息。这有助于找出哪些Goroutine处于不正常的运行状态，例如阻塞在某个操作上，或者持续循环没有结束。还可以使用go tool pprof命令行工具来进一步分析生成的profile文件，如go tool pprof http://localhost:6060/debug/pprof/goroutine，通过top命令查看占用资源较多的Goroutine函数，list命令查看特定函数内部的Goroutine调用情况等。

runtime包函数：
- 使用方式：在代码中使用runtime.Stack函数获取当前所有Goroutine的堆栈信息，例如：

package main

import (
    "fmt"
    "runtime"
)

func main() {
    var buf []byte
    buf = make([]byte, 1024*1024)
    n := runtime.Stack(buf, true)
    fmt.Println(string(buf[:n]))
}

分析：该方法会输出所有Goroutine的堆栈跟踪信息，通过分析这些信息，可以找到可能存在泄露的Goroutine及其运行的代码位置。但这种方式相对原始，对于复杂程序，手动分析堆栈信息可能比较困难。

日志记录：
- 使用方式：在Goroutine的关键节点添加日志记录，比如在Goroutine开始和结束的地方，记录相关信息，例如：

package main

import (
    "log"
)

func myGoroutine() {
    log.Println("Goroutine started")
    // 业务逻辑
    log.Println("Goroutine ended")
}

func main() {
    go myGoroutine()
    // 其他逻辑
}

分析：通过查看日志，可以了解Goroutine的生命周期，若发现有Goroutine只记录了开始而没有记录结束，可能存在泄露问题。这种方式需要在代码开发阶段就有较好的日志规划，且对于复杂程序，日志量可能较大，分析起来有一定难度。

从根本上避免Goroutine泄露的方法

正确的资源管理：
- 通道关闭：在使用通道进行通信时，确保在合适的时候关闭通道。例如，当生产者完成生产数据后，及时关闭通道，这样消费者Goroutine在读取完所有数据后会因为通道关闭而正常退出。

package main

import (
    "fmt"
)

func producer(ch chan int) {
    for i := 0; i < 10; i++ {
        ch <- i
    }
    close(ch)
}

func consumer(ch chan int) {
    for num := range ch {
        fmt.Println("Consumed:", num)
    }
}

func main() {
    ch := make(chan int)
    go producer(ch)
    go consumer(ch)
    // 防止主程序退出
    select {}
}

上下文控制：使用context.Context来管理Goroutine的生命周期。特别是在涉及到网络请求、数据库操作等有时间限制的任务中，通过上下文的取消机制，可以在外部控制Goroutine的结束。例如，在HTTP服务器处理请求时，使用context.WithTimeout设置超时时间，当超时发生时，相关的Goroutine可以收到取消信号并安全退出。

package main

import (
    "context"
    "fmt"
    "time"
)

func longRunningTask(ctx context.Context) {
    select {
    case <-ctx.Done():
        fmt.Println("Task cancelled")
        return
    case <-time.After(5 * time.Second):
        fmt.Println("Task completed")
    }
}

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
    defer cancel()
    go longRunningTask(ctx)
    // 防止主程序退出
    select {}
}

代码审查：
- 在代码审查过程中，仔细检查Goroutine的启动和结束逻辑。关注是否有Goroutine被启动后没有合理的退出机制，特别是在复杂的业务逻辑中，多层嵌套的Goroutine启动时，更要确保每一个Goroutine都有正确的结束方式。
单元测试和集成测试：
- 编写单元测试和集成测试来验证Goroutine的生命周期。例如，在测试中启动Goroutine，然后通过断言检查相关资源是否被正确释放，Goroutine是否正常结束。可以使用testing包和sync.WaitGroup来协调测试流程，确保测试的准确性。

package main

import (
    "sync"
    "testing"
)

func TestGoroutine(t *testing.T) {
    var wg sync.WaitGroup
    wg.Add(1)
    go func() {
        defer wg.Done()
        // 模拟Goroutine业务逻辑
    }()
    wg.Wait()
}

星途面试题库

面试题：Go并发程序中Goroutine泄露调试技巧

知识考点

面试题答案

检测并定位泄露的Goroutine方法和工具

从根本上避免Goroutine泄露的方法