Golang中如何解决for-loop与goroutine的问题-创新互联

这篇文章给大家分享的是有关Golang中如何解决for-loop与goroutine的问题的内容。小编觉得挺实用的，因此分享给大家做个参考，一起跟随小编过来看看吧。

目前成都创新互联已为上千多家的企业提供了网站建设、域名、网页空间、网站托管维护、企业网站设计、河东网站维护等服务，公司将坚持客户导向、应用为本的策略，正道将秉承"和谐、参与、激情"的文化，与客户和合作伙伴齐心协力一起成长，共同发展。

参见如下代码：

for i := 0; i < len(rf.peers); i++ {
  DPrintf("i = %d", i)

  if i == rf.me {
   DPrintf("skipping myself #%d", rf.me)
   continue
  }

  go func() {
   DPrintf("len of rf.peers = %d", len(rf.peers))
   DPrintf("server #%d sending request vote to server %d", rf.me, i)
   reply := &RequestVoteReply{}
   ok := rf.sendRequestVote(i, args, reply)
   if ok && reply.VoteGranted && reply.Term == rf.currentTerm {
    rf.voteCount++
    if rf.voteCount > len(rf.peers)/2 {
     rf.winElectionCh <- true
    }
   }
  }()
}

其中，peers切片的长度为3，因此最高下标为2，在非并行编程中代码中的for-loop应该是很直观的，我当时并没有意识到有什么问题。可是在调试过程中，一直在报 index out of bounds 错误。调试信息显示i的值为3，当时就一直想不明白循环条件明明是 i < 2，怎么会变成3呢。

分析

虽然不明白发生了什么，但知道应该是循环中引入的 goroutine 导致的。经过Google，发现Go的wiki中就有一个页面 Common Mistake - Using goroutines on loop iterator variables 专门提到了这个问题，看来真的是很 common 啊，笑哭~

初学者经常会使用如下代码来并行处理数据：

for val := range values {
 go val.MyMethod()
}

或者使用闭包（closure）：

for val := range values {
 go func() {
  fmt.Println(val)
 }()
}

这里的问题在于 val 实际上是一个遍历了切片中所有数据的单一变量。由于闭包只是绑定到这个 val 变量上，因此极有可能上面的代码的运行结果是所有 goroutine 都输出了切片的最后一个元素。这是因为很有可能当 for-loop 执行完之后 goroutine 才开始执行，这个时候 val 的值指向切片中最后一个元素。

The val variable in the above loops is actually a single variable that takes on the value of each slice element. Because the closures are all only bound to that one variable, there is a very good chance that when you run this code you will see the last element printed for every iteration instead of each value in sequence, because the goroutines will probably not begin executing until after the loop.

解决方法

以上代码正确的写法为：

for val := range values {
 go func(val interface{}) {
  fmt.Println(val)
 }(val)
}

在这里将 val 作为一个参数传入 goroutine 中，每个 val 都会被独立计算并保存到 goroutine 的栈中，从而得到预期的结果。

另一种方法是在循环内定义新的变量，由于在循环内定义的变量在循环遍历的过程中是不共享的，因此也可以达到同样的效果：

for i := range valslice {
 val := valslice[i]
 go func() {
  fmt.Println(val)
 }()
}

对于文章开头提到的那个问题，最简单的解决方案就是在循环内加一个临时变量，并将后面 goroutine 内的 i 都替换为这个临时变量即可：

server := i

感谢各位的阅读！关于“Golang中如何解决for-loop与goroutine的问题”这篇文章就分享到这里了，希望以上内容可以对大家有一定的帮助，让大家可以学到更多知识，如果觉得文章不错，可以把它分享出去让更多的人看到吧！

另外有需要云服务器可以了解下创新互联scvps.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

本文标题：Golang中如何解决for-loop与goroutine的问题-创新互联
标题URL：http://6mz.cn/article/ddcsps.html