實例詳解關於Golang中for-loop與goroutine

這篇文章主要給大家介紹了關於Golang中for-loop與goroutine問題的相關資料，文中透過範例程式碼介紹的非常詳細，對大家學習或使用golang具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧。

背景

最近在學習MIT的分散式課程6.824的過程中，使用Go實作Raft協定時遇到了一些問題。分享出來供大家參考學習，下面話不多說了，來一起看看詳細的介紹吧。

請參考以下程式碼：

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的詳細內容。更多資訊請關注PHP中文網其他相關文章！