Golang의 for-loop 및 goroutine의 자세한 예

이 글에서는 Golang의 for-loop 및 goroutine 문제에 대한 관련 정보를 주로 소개합니다. 이 글에서는 Golang을 배우거나 사용할 수 있는 특정 참조 학습 가치가 있습니다. 아래에서 따라해보세요. 와서 저와 함께 배워보세요.

Background

최근 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
    }
   }
  }()
}

그 중 피어 슬라이스의 길이는 3이므로 가장 높은 첨자는 2입니다. 코드의 for-loop는 비병렬 프로그래밍에서 매우 직관적이어야 합니다. .나는 아무것도 잘못되었다는 것을 깨닫지 못했습니다. 그러나 디버깅 프로세스 중에 인덱스가 범위를 벗어났다는 오류가 계속 보고되었습니다. 디버깅 정보에 따르면 i의 값은 3이었습니다. 그 당시 저는 루프 조건이 확실히 i < 2인 경우 어떻게 3이 될 수 있는지 알 수 없었습니다.

Analytics

무슨 일이 일어났는지 이해하지 못하더라도 루프에 도입된 고루틴으로 인해 발생했음을 알고 있습니다. Google을 검색한 후 Go wiki에 Common Mistake - Using goroutines on loop iterator Variables라는 페이지가 있는데 이 문제를 구체적으로 언급하는 경우가 정말 흔한 것 같습니다~

초보자는 다음 코드를 자주 사용합니다. 데이터를 병렬화하려면:

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

또는 클로저를 사용하세요:

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

여기서 문제는 val이 실제로 슬라이스의 모든 데이터를 반복하는 단일 변수라는 것입니다. 클로저는 이 val 변수에만 바인딩되므로 위 코드의 결과는 모든 고루틴이 슬라이스의 마지막 요소를 출력하는 것일 가능성이 매우 높습니다. 이는 for 루프가 실행될 때까지 고루틴이 실행을 시작하지 않을 가능성이 매우 높기 때문이며, 이때 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.

Solution

위 코드를 작성하는 올바른 방법은 다음과 같습니다.

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

여기서 val은 매개변수로 goroutine에 전달되며 각 val은 독립적으로 계산되어 저장됩니다. 예상된 결과를 얻기 위해 고루틴의 스택에 추가합니다.

또 다른 방법은 루프 내에서 새 변수를 정의하는 것입니다. 루프 내에서 정의된 변수는 루프 순회 중에 공유되지 않으므로 동일한 효과를 얻을 수 있습니다.

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

기사 시작 부분에 대해 가장 간단한 해결책 언급된 문제는 루프에 임시 변수를 추가하고 후속 goroutine의 모든 i를 다음 임시 변수로 바꾸는 것입니다:

server := i

Summary

위 내용은 Golang의 for-loop 및 goroutine의 자세한 예의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!