什么是 goroutine 泄漏？怎么排查和避免？

package main

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

func doSearch(q string) string {
	time.Sleep(time.Second) // 模拟耗时 1 秒的下游调用；实际代码中还应该把 ctx 传下去，让它也能提前结束
	return "result of " + q
}

// ❌ 调用方超时返回后，没人再接收 ch，goroutine 永远卡在发送上
func searchLeaky(ctx context.Context, q string) (string, error) {
	ch := make(chan string)
	go func() { ch <- doSearch(q) }()
	select {
	case r := <-ch:
		return r, nil
	case <-ctx.Done():
		return "", ctx.Err()
	}
}

// ✅ 缓冲为 1：即使没人接收，发送也能完成，goroutine 可以正常退出
func searchFixed(ctx context.Context, q string) (string, error) {
	ch := make(chan string, 1)
	go func() { ch <- doSearch(q) }()
	select {
	case r := <-ch:
		return r, nil
	case <-ctx.Done():
		return "", ctx.Err()
	}
}

func main() {
	check := func(name string, search func(context.Context, string) (string, error)) {
		for range 100 {
			ctx, cancel := context.WithTimeout(context.Background(), 10*time.Millisecond)
			search(ctx, "golang") // 每次都会超时
			cancel()
		}
		time.Sleep(2 * time.Second) // 留足时间让后台的 doSearch 执行完
		fmt.Println(name, runtime.NumGoroutine())
	}
	check("fixed:", searchFixed) // fixed: 1，只剩 main
	check("leaky:", searchLeaky) // leaky: 101，100 个 goroutine 永远卡在发送上
}

func startRefresher(ctx context.Context, refresh func()) {
	go func() {
		ticker := time.NewTicker(time.Minute)
		defer ticker.Stop()
		for {
			select {
			case <-ctx.Done(): // 服务关闭时取消 ctx，循环随之退出
				return
			case <-ticker.C:
				refresh()
			}
		}
	}()
}