函数在并行执行时产生不同结果？

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《函数在并行执行时产生不同结果？》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

我正在尝试同时处理文件中的行，但由于某种原因，我似乎得到了不一致的结果。我的代码的简化版本如下：

var wg sync.WaitGroup
  semaphore := make(chan struct{}, 2)
  lengths:= []int{}

  for _, file := range(args[1:]){
    // Open the file and start reading it
    reader, err := os.Open(file)
    if err != nil {
      fmt.Println("Problem reading input file:", file)
      fmt.Println("Error:", err)
      os.Exit(0)
    }
    scanner := bufio.NewScanner(reader)
    // Start streaming lines
    for scanner.Scan() {
      wg.Add(1)
      text := scanner.Text()
      semaphore <- struct{}{}
      go func(line string) {
          length := getInformation(line)
          lengths = append(lengths, length)
          <-semaphore
          wg.Done()
      }(text)
    }
  }
  wg.Wait()
  sort.Ints(lengths)
  fmt.Println("Lengths:", lengths)

getinformation 函数仅返回行的长度。然后我将这条线添加到一个数组中。我遇到的问题是，当我对同一个文件多次运行此命令时，我在数组中得到不同数量的项目。我曾假设，由于我使用的是 waitgroup，所以每次都会处理所有行，因此 lengths 的内容将是相同的，但情况似乎并非如此。谁能看到我在这里做错了什么吗？

解决方案

lengths =append(lengths, length) 正在同时执行。这是不安全的，并且会导致诸如切片中缺少条目之类的问题。您可以通过将追加调用包装在互斥体中来解决此问题，或者让 goroutine 将其结果发布到通道并有一个位置将它们收集到切片中。

终于介绍完啦！小伙伴们，这篇关于《函数在并行执行时产生不同结果？》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！