Go의 파이프라인 패턴

파이프라인 패턴은 여러 단계의 데이터를 동시에 처리하는 강력한 방법입니다. 각 단계는 데이터에 대해 서로 다른 작업을 수행한 후 다음 단계로 전달됩니다.

채널을 사용하여 데이터를 전달하면 파이프라인 패턴이 많은 경우 성능을 향상시킬 수 있습니다.

아이디어는 정말 매우 간단합니다. 각 단계는 채널을 반복하면서 더 이상 데이터가 남지 않을 때까지 데이터를 가져옵니다. 각 데이터 항목에 대해 스테이지는 해당 작업을 수행한 다음 결과를 출력 채널에 전달하고 입력 채널에 더 이상 데이터가 남아 있지 않으면 마지막으로 채널을 닫습니다. 다운스트림 단계에서 언제 종료해야 할지 알 수 있도록 채널을 닫는 것이 중요합니다

숫자 시퀀스를 만들고 두 배로 늘린 다음 낮은 값을 필터링하고 마지막으로 콘솔에 인쇄합니다.

func produce(num int) chan int {
    out := make(chan int)
    go func() {
        for i := 0; i < num; i++ {
            out <- rand.Intn(100)
        }
        close(out)
    }()
    return out
}

func double(input <-chan int) chan int {
    out := make(chan int)
    go func() {
        for value := range input {
            out <- value * 2
        }
        close(out)
    }()
    return out
}

func filterBelow10(input <-chan int) chan int {
    out := make(chan int)
    go func() {
        for value := range input {
            if value > 10 {
                out <- value
            }
        }
        close(out)
    }()
    return out
}

func print(input <-chan int) {
    for value := range input {
        fmt.Printf("value is %d\n", value)
    }
}

func main() {

    print(filterBelow10(double(produce(10))))

}

main()을 구조화하는 더 읽기 쉬운 방법이 분명히 있습니다.

func main() {

    input := produce(10)
        doubled := double(input)
    filtered := filterBelow10(doubled)
    print(filtered)

}

나의 취향에 따라 스타일을 선택해보세요.

여기에 무엇을 추가하시겠습니까? 아래에 의견을 남겨주세요.

감사합니다!

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

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