WaitGroup과 버퍼가 제한된 채널을 사용할 때 Go에서 교착 상태를 어떻게 피할 수 있나요?

WaitGroup 및 채널을 사용한 Go의 교착 상태

Go에서는 두 개 이상의 고루틴이 다른 고루틴이 끝나기를 무한정 기다릴 때 교착 상태가 발생합니다. 이 예에서는 부족한 채널 버퍼와 WaitGroup을 사용하는 고루틴의 부적절한 동기화로 인해 발생하는 교착 상태 문제를 살펴보겠습니다.

코드

<code class="go">package main

import "fmt"
import "sync"

func main() {
    ch := make(chan []int, 4)
    var m []int

    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func() {
            defer wg.Done()
            ch <- m
            return
        }()
    }
    wg.Wait()

    for c := range ch {
        fmt.Printf("c is %v", c)
    }
}</code>

문제

코드는 크기 4의 버퍼링된 채널을 통해 5개의 값을 전송하려고 시도합니다. 그러나 채널이 가득 차면 수신기를 사용할 수 있을 때까지 차단됩니다. 전송 중인 모든 고루틴이 완료되었으므로 채널에서 수신할 수 있는 것이 없습니다.

또한 채널 전체에 걸쳐 있는(for c := range ch) 고루틴도 더 많은 값을 기대하기 때문에 무기한 차단된 상태로 유지됩니다. 더 이상 전송되지 않더라도 채널에 도착합니다. 이로 인해 발신자와 수신자가 서로를 기다리는 교착 상태가 발생합니다.

해결책 1: 채널 버퍼를 늘리고 닫습니다

교착 상태를 방지하는 한 가지 해결 방법은 다음과 같습니다. 채널 버퍼 크기를 전송하는 고루틴 수보다 크거나 같은 값으로 늘립니다. 또한 모든 전송이 완료된 후 채널을 닫아야 하며 이는 더 이상 값이 수신되지 않음을 나타냅니다.

<code class="go">ch := make(chan []int, 5)
...
wg.Wait()
close(ch)</code>

해결책 2: Goroutine 수신에서 Done() 수행

또 다른 해결책은 메인 함수 대신 수신 고루틴에서 Done()을 수행하는 것입니다. 이렇게 하면 고루틴에서 값을 수신하고 사용할 때까지 WaitGroup이 감소하지 않습니다.

<code class="go">func main() {
    ch := make(chan []int, 4)
    var m []int

    var wg sync.WaitGroup
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func() {
            ch <- m
            return
        }()
    }
    go func() {
        for c := range ch {
            fmt.Printf("c is %v\n", c)
            wg.Done()
        }
    }()
    wg.Wait()
}</code>

위 내용은 WaitGroup과 버퍼가 제한된 채널을 사용할 때 Go에서 교착 상태를 어떻게 피할 수 있나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!