Go Academy · 강의

고루틴 스로틀링

동시성 제어하기

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

동시성 제한

때로는 초당 횟수를 제한하는 대신 동시에 실행되는 고루틴의 수를 제한합니다. 이렇게 하면 실행 시점과 관계없이 리소스에 가해지는 동시 부하를 제한할 수 있습니다.

병렬 실행을 제한합니다
연결 풀을 보호합니다
메모리 급증을 방지합니다

세마포어 채널

버퍼가 있는 채널은 카운팅 세마포어로 작동합니다. 용량은 최대 동시 실행 수와 같습니다. 획득할 때 토큰을 전송하고, 해제할 때 토큰을 수신합니다.

sem := make(chan struct{}, 3)

획득 및 해제

작업을 시작하기 전에 채널로 전송하여 슬롯을 획득합니다(가득 차 있으면 차단됩니다). 작업이 끝나면 수신하여 슬롯을 해제하고, 다른 고루틴이 사용할 수 있게 합니다.

sem <- struct{}{}        // acquire
// do work
<-sem                    // release

struct{}를 사용하는 이유

빈 구조체 struct{}{}는 0바이트를 차지합니다. 이를 채널 요소로 사용하면 세마포어가 메모리를 낭비하지 않는 순수한 신호가 됩니다.

반복문의 동시성 제한

각 작업마다 고루틴을 시작하되, 세마포어를 통해 각각의 실행을 제어합니다. 최대 cap개의 고루틴만 동시에 실제 작업을 수행하고, 나머지는 획득 단계에서 차단됩니다.

for _, task := range tasks {
    sem <- struct{}{}
    go func(t Task) {
        defer func() { <-sem }()
        process(t)
    }(t)
}

WaitGroup과 함께 사용하기

세마포어는 동시 실행 수를 제한하지만 모든 작업이 끝나는 시점을 알려 주지는 않습니다. 모든 작업이 끝날 때까지 기다리려면 sync.WaitGroup과 함께 사용하십시오.

var wg sync.WaitGroup
wg.Add(1)
go func() {
    defer wg.Done()
    defer func() { <-sem }()
    process(t)
}()

defer에서 해제하기

작업에서 패닉이 발생하거나 일찍 반환하더라도 슬롯이 해제되도록 항상 defer에서 해제하십시오. 해제를 잊으면 슬롯이 누수되어 결국 새로 획득하려는 작업이 교착 상태에 빠집니다.

동시성 제한을 적용한 전체 실행

이 프로그램은 작업 8개를 실행하며 동시에 실행되는 작업을 최대 2개로 제한합니다. 제한이 적용되는 모습을 보여 주기 위해 시작과 종료를 출력합니다.

package main

import (
    "fmt"
    "sync"
    "time"
)

func main() {
    sem := make(chan struct{}, 2)
    var wg sync.WaitGroup
    for i := 0; i < 8; i++ {
        wg.Add(1)
        sem <- struct{}{}
        go func(id int) {
            defer wg.Done()
            defer func() { <-sem }()
            fmt.Println("start", id)
            time.Sleep(20 * time.Millisecond)
            fmt.Println("end", id)
        }(i)
    }
    wg.Wait()
    fmt.Println("done")
}

errgroup과 SetLimit 사용하기

golang.org/x/sync/errgroup 패키지는 SetLimit을 제공하여 그룹의 실행을 제한하고 첫 번째 오류를 전파합니다. 외부 패키지라는 점은 있지만, 많은 경우 더 깔끔한 대안입니다.

동시성 제한과 작업자 풀 비교

작업자 풀은 고정된 수의 고루틴을 재사용하며 큐에서 작업을 가져옵니다. 세마포어를 이용한 동시성 제한은 작업마다 고루틴을 시작하되 활성 고루틴 수를 제한합니다. 작업 수가 매우 많을 때는 풀이 더 효율적이고, 세마포어는 기존 코드에 붙이기 더 간단합니다.

제한 값 선택

데이터베이스 호출에서는 연결 풀 크기 이하로 제한 값을 설정하십시오. 외부 HTTP 요청에서는 호스트의 연결 제한에 맞추십시오. 너무 높으면 리소스가 고갈되고, 너무 낮으면 용량을 낭비합니다.

빠른 확인

동시성 제한에 대한 지식을 확인해 보십시오.

복습

고루틴 동시성 제한에 대해 배웠습니다:

버퍼가 있는 채널은 카운팅 세마포어로 작동합니다
전송으로 획득하고, defer에서 수신하여 해제합니다
struct{} 요소는 0바이트를 사용합니다
완료를 기다리려면 WaitGroup과 함께 사용합니다
보호하려는 리소스에 맞춰 제한 크기를 정합니다

자주 묻는 질문

“고루틴 스로틀링” 강의는 무료인가요?

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

“고루틴 스로틀링”에서 뭘 배우나요?

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

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

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

“고루틴 스로틀링” 강의는 얼마나 걸리나요?

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

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

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

이 강의의 모든 강의

← Go Academy(으)로 돌아가기