如何等待 goroutine 完成并在没有锁的情况下读取通道？

Question

我在这里查看了一些关于 SO 的示例和问题，但仍然无法让一个相当简单的代码按预期工作：

func main() {
    ch := make(chan string)
    var wg sync.WaitGroup
    wg.Add(2)
    go readFile("A", ch, wg)
    go readFile("B", ch, wg)
    go func() {
        wg.Wait()
        close(ch)
    }()
    printer(ch)
}

func readFile(name string, ch chan string, wg sync.WaitGroup) {
    file, err := os.Open(name)
    if err != nil {
        fmt.Errorf("was not able to read from file %s: %s", name, err)
    }
    scanner := bufio.NewScanner(file)
    for scanner.Scan() {
        ch <- scanner.Text()
    }
    wg.Done()
}

func printer(ch chan string) {
    for val := range ch {
        fmt.Println(val)
    }
}

所以我从两个文件中读取，将读取的行推送到一个通道中，然后简单地打印出来（一些代码是从不需要的细节中简化的）

两个 goroutine，两个都是 WaitGroup，用 Wait 修复 goroutine 并关闭通道。

从我的角度来看，这与这个问题和 exepted 答案几乎相同：Let golang close used channel after all goroutines finished

那么我的情况有什么问题？

Answer 1

首先遵循sync.WaitGroup 说明的文档：

Package sync

import "sync"

type WaitGroup

WaitGroup 等待一组 goroutine 完成。主要的 goroutine 调用 Add 来设置要等待的 goroutine 的数量。然后 每个 goroutine 运行并在完成时调用 Done。同时 时间，Wait 可以用来阻塞，直到所有的 goroutine 都完成。

WaitGroup 首次使用后不得复制。

---

WaitGroup 首次使用后不得复制。