如何使用goroutine执行for循环？

Question

假设我有这样的切片：

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]来获取值。

Answer 1

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

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 循环与它启动的 goroutines 同时运行）。 for 很可能在任何 goroutine 之前完成，这意味着所有输出都将存储在 studentList 的最后一个元素中（它们将相互覆盖，因此您最终会得到一个值） .

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

学生列表的输出

你没有在问题中说，但我怀疑你在 for 循环完成后立即运行 fmt.Println(studentList[1] （或类似）。如上所述，很有可能 none 的 goroutines 在那个时候已经完成（或者他们可能，你不知道）。使用 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。

Answer 2

不是因为这个

the goroutine is out-of-order to execute

这里至少有两个问题：

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

多个goroutines读取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()

P.S.:（警告：可能并不总是正确的）
这一行 studentList[i], err = getList(st) , 虽然它可能不会导致数据竞争，但它对 cpu 缓存行不友好。最好避免编写这样的代码。

如何使用goroutine执行for循环？

How can I use goroutine to execute for loop?

go

goroutine