Go编程语言的所有 Goroutine 都处于等待状态

golang学习网今天将给大家带来《Go编程语言的所有 Goroutine 都处于等待状态》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

我正在学习 go 编程语言并学习 goroutine，并遇到了以下问题。在此示例中，以下函数旨在获取文件通道并处理每个文件：

func makethumbnails5(filenames <-chan string) int64 {
    sizes := make(chan int64)
    var wg sync.waitgroup
    for f := range filenames {
        wg.add(1)
        // worker
        go func(f string) {
            defer wg.done()
            thumb, err := thumbnail.imagefile(f)
            if err != nil {
                log.println(err)
                return
            }
            info, _ := os.stat(thumb)
            sizes <- info.size()
        }(f)
    }

    // closer
    go func() {
        wg.wait()
        close(sizes)
    }()

    var total int64
    for size := range sizes {
        total += size
    }

    wg.wait()
    return total
}

我尝试通过以下方式使用此功能：

func main() {
    thumbnails := os.args[1:] /* get a list of all the images from the cli */
    ch := make(chan string, len(thumbnails))
    for _, val := range thumbnails {
        ch <- val
    }
    makethumbnails5(ch)
}

但是，当我运行该程序时，出现以下错误：

fatal error: all goroutines are asleep - deadlock!

看起来更近的 goroutine 并没有在运行。有人可以帮助我理解这里出了什么问题，以及我可以做些什么来正确运行这个函数吗？

正确答案

正如我评论的那样，它死锁，因为 filenames chan 永远不会关闭，因此 for f := range filenames 循环永远不会完成。然而，仅仅关闭输入 chan 意味着循环中启动的所有 goroutine 都会卡在 sizes <- info.size() 行，直到循环结束。在这种情况下这不是问题，但如果输入可能很大，则可能会很大（那么您可能也想限制并发工作人员的数量）。因此，将主循环放在 goroutine 中也是有意义的，以便 for size := rangesized 循环可以开始消耗。以下应该有效：

func makethumbnails5(filenames <-chan string) int64 {
    sizes := make(chan int64)
    var wg sync.waitgroup
    wg.add(1)
    go func() {
        defer wg.done()
        for f := range filenames {
            wg.add(1)
            // worker
            go func(f string) {
                defer wg.done()
                thumb, err := thumbnail.imagefile(f)
                if err != nil {
                    log.println(err)
                    return
                }
                info, _ := os.stat(thumb)
                sizes <- info.size()
            }(f)
        }
    }()

    // closer
    go func() {
        wg.wait()
        close(sizes)
    }()

    var total int64
    for size := range sizes {
        total += size
    }

    return total
}

main 的实现也有类似的问题，如果输入很大，那么在将其传递到进行处理之前，您实际上会将其全部加载到内存中（缓冲 chan）。也许像下面这样的东西更好

func main() {
    ch := make(chan string)
    go func(thumbnails []string) {
        defer close(ch)
        for _, val := range thumbnails {
            ch <- val
        }
    }(os.Args[1:])
    makeThumbnails5(ch)
}

到这里，我们也就讲完了《Go编程语言的所有 Goroutine 都处于等待状态》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！