workers.go

func worker(line string) []string {
  // do your phone# parsing
  return []string{}
}

func main() {
  fn := os.Args[1]
  numWorkers := 10
  srcChans := make([]chan interface{}, numWorkers)
  outChan := make(chan []string, 1024)
  var wg sync.WaitGroup
  wg.Add(numWorkers)
  
  for i := 0; i < numWorkers; i++ {
    srcChans[i] = make(chan interface{})
    go func(i int) {
      defer wg.Done()
      for item := range srcChans[i] {
        outChan <- worker(item.(string))
      }
    }(i)
  }
  
  go func() {
    wg.Wait()
    close(outChan)
  }()
    
  gomr.TextFileParallel(fn, srcChans)
    
  for item := range outChan {
    fmt.Println(item)
  }
}

This is a program that uses my mapreduce library's (github.com/cnnrznn/gomr) file reader to read input into multiple Go channels concurrently. This allows for concurrently processing of a file in chunks.

The library provides input split on the newline character.