递归遍历目录时如何限制Goroutine数量？代码遇chan send panic求助

你的代码中启用注释的limit通道逻辑会出现问题，核心原因是信号量的释放逻辑没有覆盖所有代码路径——比如当os.ReadDir返回错误时，函数直接走到末尾，若此时分支判断未触发，会导致信号未正确释放，进而引发通道操作的panic或死锁。

下面是修正后的实现，通过信号量（带缓冲通道）严格控制并发Goroutine数量：

package main

import (
    "fmt"
    "os"
    "runtime"
    "sync"
    "time"
)

var (
    wg    sync.WaitGroup
    limit = make(chan bool, 20) // 限制并发数为20
)

func Work(path string) {
    fmt.Printf("当前Goroutine数量: %d\n", runtime.NumGoroutine())
    defer func() {
        wg.Done()
        <-limit // 释放信号量，defer确保无论函数如何退出都能执行
    }()

    fl, err := os.ReadDir(path)
    if err != nil {
        fmt.Printf("读取目录失败: %v\n", err)
        return
    }

    for _, file := range fl {
        fullPath := path + "/" + file.Name() // 修复路径拼接，避免连续斜杠
        if file.IsDir() {
            limit <- true // 获取信号量，缓冲满时阻塞，控制并发数
            wg.Add(1)
            go Work(fullPath)
        } else {
            // 这里可添加文件处理逻辑，示例仅打印路径
            fmt.Printf("文件: %s\n", fullPath)
        }
    }
}

func main() {
    path := "C:/Windows/"
    start := time.Now()

    // 第一个协程也占用信号量，确保总并发不超过限制
    wg.Add(1)
    limit <- true
    go Work(path)

    wg.Wait()
    close(limit) // 程序结束前关闭通道（可选）

    fmt.Printf("遍历完成，耗时: %v\n", time.Since(start))
}

关键改动说明： #

• 信号量安全管理：启动新协程前先执行limit <- true获取信号，协程内部用defer <-limit确保无论正常结束还是出错，都能释放信号，避免信号泄漏。
• 路径拼接修复：原代码拼接路径会产生连续斜杠（如C:/Windows/System32//file.txt），改为规范的拼接方式。
• 错误处理完善：添加os.ReadDir的错误打印，便于调试异常场景。
• 严格并发控制：第一个协程也占用信号量，保证总并发数严格不超过limit的缓冲大小。

原代码panic原因 #

启用你注释的逻辑后，若多个协程启动导致limit通道缓冲被占满，后续的limit <- true会阻塞；如果某个协程因错误提前返回且未执行<-limit释放信号，通道会一直处于满状态，阻塞的协程无法继续，最终引发死锁或程序退出时协程仍操作通道导致panic。

内容的提问来源于stack exchange，提问作者alex