同时读取文件

偷偷努力，悄无声息地变强，然后惊艳所有人！哈哈，小伙伴们又来学习啦~今天我将给大家介绍《同时读取文件》，这篇文章主要会讲到golang等等知识点，不知道大家对其都有多少了解，下面我们就一起来看一吧！当然，非常希望大家能多多评论，给出合理的建议，我们一起学习，一起进步！

问题内容

读取部分不是并发的，但处理是并发的。我以这种方式表述标题是因为我最有可能使用该短语再次搜索此问题。:)

在尝试超越示例 之后，我遇到了僵局，所以这对我来说是一次学习经历。我的目标是：

1. 逐行读取文件（最终使用缓冲区来执行行组）。
2. 将文本传递给func()执行一些正则表达式的工作。
3. 将结果发送到某处，但避免使用互斥锁或共享变量。我正在向频道发送整数（始终为数字 1）。这有点傻，但如果它没有引起问题，我想这样离开它，除非你们有更整洁的选择。
4. 使用工作池来执行此操作。我不知道我如何告诉工人重新排队？

这是操场链接。我试图写有用的评论，希望这是有道理的。我的设计可能完全错误，所以不要犹豫重构。

package main

import (
  "bufio"
  "fmt"
  "regexp"
  "strings"
  "sync"
)

func telephoneNumbersInFile(path string) int {
  file := strings.NewReader(path)

  var telephone = regexp.MustCompile(`\(\d+\)\s\d+-\d+`)

  // do I need buffered channels here?
  jobs := make(chan string)
  results := make(chan int)

  // I think we need a wait group, not sure.
  wg := new(sync.WaitGroup)

  // start up some workers that will block and wait?
  for w := 1; w 

    正确答案

你快到了，只需要在 goroutines 的同步上做一些工作。您的问题是您试图在同一个例程中提供解析器并收集结果，但这无法完成。
我提出以下建议：
在单独的例程中运行扫描仪，读取所有内容后关闭输入通道。
运行单独的例程等待解析器完成他们的工作，而不是关闭输出通道。
在您的主程序中收集所有结果。
相关更改可能如下所示：
// Go over a file line by line and queue up a ton of work
go func() {
    scanner := bufio.NewScanner(file)
    for scanner.Scan() {
        jobs 
操场上的完整工作示例：http ://play.golang.org/p/coja1_w-
fY
值得补充的是，您不一定需要WaitGroup达到相同的效果，您只需要知道何时停止接收结果。这可以通过例如扫描器广告（在通道上）读取了多少行然后收集器仅读取指定数量的结果来实现（尽管您也需要发送零）。
好了，本文到此结束，带大家了解了《同时读取文件》，希望本文对你有所帮助！关注golang学习网公众号，给大家分享更多Golang知识！