Go에서 동시에 실행되는 고루틴의 수를 일정하게 유지하는 방법은 무엇입니까?

Go에서 고루틴 스레딩: 상수를 동시에 실행

Go 동시성 영역은 지정된 수의 고루틴이 완료되기를 기다리는 데 필요한 수많은 자료를 제공합니다. 그러나 뚜렷한 과제가 있습니다. 사전 정의된 수의 고루틴을 연속적으로 실행하고 하나가 시작되면 다른 고루틴이 종료되도록 보장하는 것입니다.

MySQL에서 검색된 데이터 처리와 같이 상당한 양의 작업이 포함된 시나리오를 생각해 보세요. 데이터 베이스. 순진한 접근 방식은 수많은 병렬 고루틴을 시작하여 수십만 개의 작업을 동시에 실행할 수 있습니다. 대조적으로, 원하는 동작은 동시에 실행되는 고루틴을 고정 개수(예: 20)로 제한합니다.

이 제어된 동시성 패턴을 "제한된 병렬 처리"라고 합니다. Go에서 이 패턴을 구현하려면 빈 구조체 채널을 세마포로 사용하여 최대 동시 작업자 고루틴 수를 지정해야 합니다. 그림은 다음과 같습니다.

package main

import "fmt"

func main() {
    maxGoroutines := 10
    guard := make(chan struct{}, maxGoroutines)

    for i := 0; i < 30; i++ {
        guard <- struct{}{} // blocks if guard channel is full
        go func(n int) {
            worker(n)
            <-guard // unlocks a slot in guard
        }(i)
    }
}

func worker(i int) { fmt.Println("doing work on", i) }

이 구현은 지정된 수 이상의 고루틴이 동시에 실행되지 않도록 보장합니다. 결과적으로 작업자 고루틴이 완료되면 새로운 고루틴이 즉시 시작되어 원하는 동시성 수준을 유지합니다.

"Go 동시성 패턴" 기사의 "제한된 병렬성" 섹션에서 이 개념을 더 자세히 탐구하여 더 깊은 정보를 제공합니다. 이 중요한 동시성 기술에 대한 통찰력을 제공합니다.

위 내용은 Go에서 동시에 실행되는 고루틴의 수를 일정하게 유지하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!