이동 채널을 닫을 때의 이동 조건

Question

다음 Go 코드 예에서는 c <- byte(0)과 close(c) 사이의 경쟁 조건이 있습니다. 코드가 go test -race으로 실행되면 신호가 보내집니다.

func TestRace(t *testing.T) { 
    var c = make(chan byte, 20) 
    go func() { 
     defer func() { 
      if r := recover(); r == nil { 
       t.Error("expected panic error") 
      } 
     }() 
     for i := 0; i < 25; i++ { 
      c <- byte(0) 
     } 
     t.Error("expected a panic") 
    }() 
    close(c) 
} 

어떻게하면이 경쟁 조건을 피할 수 있습니까?

편집 :

func TestRace(t *testing.T) { 
    var c = make(chan byte, 20) 
    var done = make(chan struct{}) 
    go func() { 
     for i := 0; i < 25; i++ { 
      select{ 
      case c <- byte(0): 
      case <-done: 
       close(c) 
       return 
     } 
    }() 
    close(done) 
} 

이 경쟁 조건이되지 않고 깨끗합니다 그의 의견에 Icza 제안에 따라, 여기에 솔루션입니다. 그것은 어리석은 간단한 예입니다. select가 오버 헤드를 추가한다고 들었지만, 사용 사례와 관련이 없기 때문에이를 조사하지 않았습니다.

Answer 1

일반적으로 채널에 값을 보내는 goroutine이이를 닫아야합니다. 채널을 닫는 것은 기본적으로 더 이상 값을 보낼 수 없다는 신호입니다.

당신은 이것을하지 않습니다 : 당신의 새로운 goroutine은 값을 보내는 것이고 다른 goroutine은 그것을 닫는 것입니다. 거기에 값을 보내는 goroutine, 예컨대 :

go func() { 
    defer func() { 
     if r := recover(); r == nil { 
      fmt.Println("expected panic error") 
     } 
    }() 
    for i := 0; i < 25; i++ { 
     c <- byte(0) 
    } 
    close(c) 
    fmt.Println("expected a panic") 
}() 
for x := range c { 
    fmt.Println("Received:", x) 
} 

가 Go Playground에 그것을 시도하는 close(c) 전화를 이동 :

그들이 의도 한대로 단순히 채널을 사용, 경쟁 조건을 제거하는.