Go의 패닌 패턴

팬인 패턴을 살펴보겠습니다. 이는 Go에서 여러 스레드의 관련 데이터를 함께 가져와야 할 때 매우 유용합니다.

예를 들어, 서로 다른 서비스에 대해 여러 API 호출을 수행했고 그 결과를 결합해야 한다고 가정해 보세요.

이것은 구현하기 정말 쉬운 패턴이지만 채널을 처리하는 방법에 주의를 기울여야 합니다. 교착상태에 빠지기 쉽습니다.

// produce is used to simulate the different data sources
func produce(id int) chan int {
    ch := make(chan int)
    go func() {
        for i := 0; i < 10; i++ {
            ch <- id*10 + i
        }
        fmt.Printf("producer %d done\n", id)
        close(ch) // this is important!!!
    }()
    return ch
}

func fanin(inputs ...chan int) chan int {
    output := make(chan int)

    var wg sync.WaitGroup
    for i, input := range inputs {
        wg.Add(1)
        go func() {
            for value := range input {
                output <- value
            }
            fmt.Printf("done merging source %d\n", i)
            wg.Done()
        }()
    }
    go func() {
        wg.Wait()
        close(output) // this is important!!!
    }()

    return output
}

func main() {
    input1 := produce(0)
    input2 := produce(1)

    result := fanin(input1, input2)

    done := make(chan bool)
    go func() {
        for value := range result {
            fmt.Printf("got %d\n", value)
        }
        close(done)
    }()
    <-done
    fmt.Println("done")
}

여기서는 생산 기능을 사용하여 다양한 소스를 시뮬레이션합니다. 이러한 소스 채널은 결합 작업을 수행하는 fanin 기능으로 전송됩니다.

fanin 함수는 출력 채널을 생성한 다음 각 입력에서 작동하는 고루틴을 시작합니다. WaitGroup을 사용하여 모든 입력 소스가 출력 채널에 결합된 시기를 나타냅니다.

이 간단한 예에서 메인 스레드는 출력을 반복합니다. 순서에 대한 보장은 없으며 2개 입력의 값이 혼합되어 있습니다.

가장 중요한 점은 입력 결합이 끝나면 출력 채널을 닫아야 한다는 것입니다. 범위 연산자는 채널이 비어 있으면 무기한 대기합니다. close(output) 행을 주석 처리하면 교착 상태가 발생하는 것을 볼 수 있습니다.

이 문제를 어떻게 개선할 수 있나요? 아래에 댓글을 남겨주세요.

감사합니다!

이 게시물과 이 시리즈의 모든 게시물에 대한 코드는 여기에서 확인할 수 있습니다

위 내용은 Go의 패닌 패턴의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!