在Golang中同时读取文件

您快要准备好了，只需要在goroutine的同步上做一些工作即可。您的问题是您试图在相同的例程中提供解析器并收集结果，但这无法完成。

我提出以下建议：

1. 在单独的例程中运行扫描仪，读取所有内容后关闭输入通道。
2. 运行单独的例程，等待解析器完成工作，然后关闭输出通道。
3. 在主例程中收集所有结果。

相关更改如下所示：

// Go over a file line by line and queue up a ton of workgo func() {    scanner := bufio.NewScanner(file)    for scanner.Scan() {        jobs <- scanner.Text()    }    close(jobs)}()// Collect all the results...// First, make sure we close the result channel when everything was processedgo func() {    wg.Wait()    close(results)}()// Now, add up the results from the results channel until closedcounts := 0for v := range results {    counts += v}

在操场上完全可用的示例：http :
//play.golang.org/p/coja1_w-fY

值得补充的是，您不一定需要

WaitGroup