如何在Go语言中使用goroutine来并发执行for循环？

golang学习网今天将给大家带来《如何在Go语言中使用goroutine来并发执行for循环？》，感兴趣的朋友请继续看下去吧！以下内容将会涉及到等等知识点，如果你是正在学习Golang或者已经是大佬级别了，都非常欢迎也希望大家都能给我建议评论哈~希望能帮助到大家！

假设我有一个像这样的切片：

stu = [{"id":"001","name":"a"} {"id":"002", "name":"b"}] 或许还有更多这样的元素。切片内部是一个长字符串，我想使用 json.unmarshal 来解析它。

type Student struct {
   Id   string `json:"id"`
   Name string `json:"name"`
}

studentList := make([]Student,len(stu))
for i, st := range stu {
   go func(st string){
      studentList[i], err = getList(st)
      if err != nil {
         return ... //just example
      }
   }(st)
}
//and a function like this
func getList(stu string)(res Student, error){
   var student Student
   err := json.Unmarshal(([]byte)(stu), &student)
   if err != nil {
      return
   }
   return &student,nil
}

我得到了nil结果，所以我会说goroutine执行时是乱序的，所以我不知道它是否可以使用studentlist[i]来获取值。

正确答案

以下是您的代码的一些潜在问题：

i 的值可能不是您所期望的

for i, st := range stu {
   go func(st string){
      studentlist[i], err = getlist(st)
      if err != nil {
         return ... //just example
      }
   }(st)
}

您启动了许多 goroutine，并在其中引用 i。问题是 i 可能在您启动 goroutine 和 goroutine 引用它的时间之间发生了变化（for 循环与它启动的 goroutine 同时运行）。 for 很可能在任何 goroutine 之前完成，这意味着所有输出都将存储在 studentlist 的最后一个元素中（它们将相互覆盖，因此最终会得到一个值）。

一个简单的解决方案是将 i 传递到 goroutine 函数中（例如 go func(st string, i int){}(st, i) （这会创建一个副本）。请参阅 this for more info。

studentlist 的输出

你没有在问题中说，但我怀疑你在 for 循环完成后立即运行 fmt.println(studentlist[1] （或类似的）。如上所述，很可能没有一个 goroutine 完成到那时（或者他们可能会，你不知道）。使用 waitgroup 是解决这个问题的一个相当简单的方法：

var wg sync.waitgroup
wg.add(len(stu))
for i, st := range stu {
    go func(st string, i int) {
        var err error
        studentlist[i], err = getlist(st)
        if err != nil {
            panic(err)
        }
        wg.done()
    }(st, i)
}
wg.wait()

我已经纠正了这些问题in the playground。

不是因为这个

这里至少有两个问题：

你不应该在goroutine中使用for循环变量i。

多个goroutine读取i，for循环修改i，这里是竞争条件。要使 i 按预期工作，请将代码更改为：

for i, st := range stu {
   go func(i int, st string){
      studentlist[i], err = getlist(st)
      if err != nil {
         return ... //just example
      }
   }(i, st)
}

此外，使用 sync.waitgroup 来等待所有 goroutine。

var wg sync.WaitGroup
for i, st := range stu {
   wg.Add(1)
   go func(i int, st string){
      defer wg.Done()

      studentList[i], err = getList(st)
      if err != nil {
         return ... //just example
      }
   }(i, st)
}

wg.Wait()

ps：（警告：也许并不总是如此）
这一行 studentlist[i], err = getlist(st) ， 虽然它可能不会导致数据竞争，但它对 cpu 缓存线不友好。最好避免编写这样的代码。

到这里，我们也就讲完了《如何在Go语言中使用goroutine来并发执行for循环？》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！