像检测内存泄露一样检测goroutine泄露? goroutineleak 帮助我们更快的定位goroutine leak

go install golang.org/dl/gotip@latest
gotip download

func main() {
// Start pprof server to expose goroutineleak profile
gofunc() {
  log.Printf("pprof server started at http://localhost:6060")
if err := http.ListenAndServe(":6060", nil); err != nil {
   log.Fatalf("failed to start pprof server: %v", err)
  }
 }()

// Create a goroutine leak
 createLeakedGoroutine()

// Keep the program running to allow pprof inspection
 fmt.Println("Demo program running...")
 fmt.Println("Use this command to check for leaks:")
 fmt.Println("   GOEXPERIMENT=goroutineleakprofile gotip tool pprof http://localhost:6060/debug/pprof/goroutineleak")
 fmt.Println("Press Ctrl+C to exit")

// Wait for interrupt signal to gracefully exit
 sigCh := make(chan os.Signal, 1)
 signal.Notify(sigCh, syscall.SIGINT, syscall.SIGTERM)
 <-sigCh

 log.Println("Shutting down demo program...")
}

// createLeakedGoroutine intentionally creates a leaked goroutine
funccreateLeakedGoroutine() {
// Create a channel but never write to it or close it
 ch := make(chanint)

// Start a goroutine that blocks forever on channel receive
gofunc() {
  fmt.Println("Leaked goroutine started - waiting for channel data")
  <-ch // This goroutine will never return
  fmt.Println("Leaked goroutine should never reach this line")
 }()

// The channel 'ch' is not accessible after this function returns,
// so both the channel and the goroutine are leaked
 fmt.Println("Created a leaked goroutine - channel is now unreachable")
}

# 启动带有泄露检测的程序
GOEXPERIMENT=goroutineleakprofile gotip run main.go

# 使用专门的泄露检测profile
GOEXPERIMENT=goroutineleakprofile gotip tool pprof http://localhost:6060/debug/pprof/goroutineleak

# 查看泄露的goroutine
(pprof) top
Showing nodes accounting for 1, 100% of 1 total
      flat  flat%   sum%        cum   cum%
         1   100%   100%          1   100%  runtime.gopark
         0     0%   100%          1   100%  main.createLeakedGoroutine.func1
         0     0%   100%          1   100%  runtime.chanrecv
         0     0%   100%          1   100%  runtime.chanrecv1

# 查看泄露点的具体代码
(pprof) list main.createLeakedGoroutine.func1
Total: 1
ROUTINE ======================== main.createLeakedGoroutine.func1 in /path/to/goroutineleak_example/main.go
         1          1 (flat, cum)   100% of Total
            .          .     27:func createLeakedGoroutine() {
            .          .     28: // Create a channel but never write to it or close it
            .          .     29: ch := make(chan int)
            .          .     30:
            .          .     31: // Start a goroutine that blocks forever on channel receive
            .          .     32: go func() {
            .          .     33:  fmt.Println("Leaked goroutine started - waiting for channel data")
         1          1     34:  <-ch // This goroutine will never return
            .          .     35:  fmt.Println("Leaked goroutine should never reach this line")
            .          .     36: }()
            .          .     37:
            .          .     38: // The channel 'ch' is not accessible after this function returns,
            .          .     39: // so both the channel and the goroutine are leaked
            .          .     40: fmt.Println("Created a leaked goroutine - channel is now unreachable")
            .          .     41:}