Go Academy · 강의

파이프라인과 단계 패턴

Q: “파이프라인과 단계 패턴” 강의는 무료인가요?

네 — “파이프라인과 단계 패턴” 전체 내용을 이 웹사이트에서 무료로 읽을 수 있습니다. 인터랙티브하게 실습하려면(내장 코드 에디터와 24/7 AI 튜터), CoddyKit PRO로 업그레이드하면 Go Academy 강의 전체를 잠금 해제할 수 있습니다. Go Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

Q: “파이프라인과 단계 패턴”에서 뭘 배우나요?

다단계 동시성 파이프라인을 조합합니다. 브라우저에서 직접 실행하는 실습 코드로 Go Academy을(를) 배우며, 24/7 AI 튜터가 강의를 진행하면서 질문에 답변해줍니다.

Q: Go Academy을(를) 시작하는 데 경험이 필요한가요?

사전 경험은 필요하지 않습니다. CoddyKit의 Go Academy은(는) 초급자부터 고급 학습자까지를 위해 구성되어 있으므로, 여기서 시작하거나 처음부터 시작할 수 있으며 자신의 속도대로 진행할 수 있습니다. 이것은 4개 중 1번째 강의입니다.

Q: “파이프라인과 단계 패턴” 강의는 얼마나 걸리나요?

대부분의 CoddyKit 강의는 약 5~10분이 소요됩니다. 각 강의는 간결하고 인터랙티브하여 꾸준한 진행이 가능하며, 웹과 앱에서 중단한 부분부터 바로 시작할 수 있습니다.

Q: 이 Go Academy 강의에서 코드를 작성하고 실행할 수 있나요?

네. 모든 Go Academy 강의에는 내장 코드 에디터가 포함되어 있으므로, 브라우저에서 바로 실제 코드를 작성하고 실행한 후 즉시 AI 피드백을 받을 수 있습니다 — 로컬 설정이 필요 없습니다.

다단계 동시성 파이프라인을 조합합니다.

파이프라인과 단계 패턴은(는) CoddyKit의 무료 Go Academy 강의입니다. 이것은 4개 중 1번째 강의입니다. 아래에서 전체 강의를 무료로 읽을 수 있으며, 내장 코드 에디터와 24/7 AI 튜터와 함께 브라우저에서 직접 실습할 수 있습니다. 이 강의는 Go Academy 학습 경로의 일부이며, 진행 상황이 웹과 CoddyKit 앱에 동기화됩니다. Go Academy 강의에는 총 4개의 강의가 포함되어 있습니다.

파이프라인이란 무엇인가요

동시성 파이프라인은 채널로 연결된 일련의 단계입니다. 각 단계는 이전 단계에서 값을 받아 변환한 뒤 다음 단계로 결과를 보내므로, 단계들이 동시에 실행될 수 있습니다.

간단한 3단계 파이프라인

Generate → 변환 → 소비:

func generate(nums ...int) <-chan int {
    out := make(chan int)
    go func() { defer close(out); for _, n := range nums { out <- n } }()
    return out
}
func square(in <-chan int) <-chan int {
    out := make(chan int)
    go func() { defer close(out); for n := range in { out <- n*n } }()
    return out
}

for v := range square(generate(2, 3, 4)) {
    fmt.Println(v) // 4, 9, 16
}

단계 패턴

각 단계는 입력 채널을 받아 출력 채널을 반환하는 함수입니다. 단계는 깔끔하게 조합할 수 있고 독립적으로 병렬화할 수 있습니다.

파이프라인 내부의 팬아웃

CPU를 많이 사용하는 작업을 병렬화하려면 하나의 단계를 N개의 고루틴으로 분기합니다:

func parallelSquare(in <-chan int, n int) <-chan int {
    outs := make([]<-chan int, n)
    for i := 0; i < n; i++ {
        outs[i] = square(in) // all read from same in
    }
    return merge(outs...)
}

컨텍스트를 사용한 취소

각 단계에 컨텍스트를 전달합니다. 컨텍스트가 취소되면 단계는 읽기를 중단하고 출력 채널을 닫아 전체 파이프라인이 정리되도록 합니다.

func stage(ctx context.Context, in <-chan int) <-chan int {
    out := make(chan int)
    go func() {
        defer close(out)
        for {
            select {
            case v, ok := <-in:
                if !ok { return }
                select {
                case out <- process(v):
                case <-ctx.Done(): return
                }
            case <-ctx.Done(): return
            }
        }
    }()
    return out
}

역압

단계 사이에 버퍼가 있는 채널을 사용하여 생산자와 소비자의 처리 속도를 분리합니다. 버퍼가 없으면 느린 단계가 전체 파이프라인을 멈추게 합니다.

out := make(chan Result, 50) // buffer 50 results

오류 전파

패닉을 일으키지 않고 파이프라인을 통해 오류를 전파하려면 값을 결과 구조체로 감쌉니다:

type item struct { val int; err error }

Done 채널 패턴

더 단순한 파이프라인에서는 컨텍스트 대신 Done 채널을 사용할 수 있습니다. 모든 단계에 중단 신호를 보내려면 Done을 닫습니다.

done := make(chan struct{})
defer close(done)

순서 보장

각 단계가 순차적으로 실행되면 단순한 파이프라인은 순서를 유지합니다. 병렬화된 단계는 순서를 유지하지 않으므로, 필요한 경우 인덱스 필드를 사용해 다음 단계에서 결과를 다시 정렬합니다.

WaitGroup을 사용하는 파이프라인

마지막 단계는 채널을 닫을 필요 없이 채널을 순회하기만 하면 됩니다. 팬인에서는 모든 생산자 고루틴이 완료된 후 병합된 채널을 닫도록 WaitGroup을 사용합니다.

실제 활용 사례

파이프라인의 일반적인 활용 사례로는 ETL 데이터 처리, 이미지 크기 조정, 로그 분석, 빌드 시스템, 스트리밍 요청 처리기가 있습니다.

빠른 확인

여러 단계로 이루어진 파이프라인 전체에 취소를 어떻게 전파하나요?

복습: 파이프라인 패턴

핵심 내용:

단계: func(in <-chan T) <-chan U — 조합하여 파이프라인을 구성합니다
컨텍스트를 통해 취소하고, 버퍼가 있는 채널을 통해 역압을 처리합니다
병렬 처리를 위해 단계 내부에서 팬아웃합니다
오류 전파를 위해 값을 결과 구조체로 감쌉니다

자주 묻는 질문