如何在Golang中避免goroutine泄露

ctx, cancel := context.WithTimeout(context.Background(), 5*time.Second)
defer cancel()
<p>go func(ctx context.Context) {
for {
select {
case <-ctx.Done():
fmt.Println("goroutine exiting due to context cancellation")
return
default:
// 执行一些工作
time.Sleep(1 * time.Second)
}
}
}(ctx)</p><p>// 主程序等待或做其他事
<-ctx.Done()</p>

ch := make(chan int)
go func() {
    for value := range ch { // range会自动检测channel关闭
        fmt.Println("Received:", value)
    }
    fmt.Println("Goroutine exiting...")
}()
<p>// 发送数据
ch <- 1
ch <- 2
close(ch) // 关键：关闭channel以通知接收方结束
time.Sleep(time.Second)</p>

ch1, ch2 := make(chan int), make(chan int)
go func() {
    for {
        select {
        case v := <-ch1:
            fmt.Println(v)
        case v := <-ch2:
            fmt.Println(v)
        }
    }
}()

done := make(chan struct{})
go func() {
    defer close(done)
    for {
        select {
        case v := <-ch1:
            fmt.Println(v)
        case v := <-ch2:
            fmt.Println(v)
        case <-done:
            return
        }
    }
}()

import _ "net/http/pprof"
// 启动服务后访问 /debug/pprof/goroutine 可查看goroutine堆栈