Go 언어의 동시성 수를 제어하는 ​​방법

Go 언어는 동시성을 지원하기 때문에 인터뷰에서 동시성 질문을 자주 받습니다. 예를 들어 Go에서 동시성 수를 제어하는 ​​방법은 무엇입니까? 다음은 제가 개인적으로 컴파일한 두 가지 예입니다.

func waitGroup() {
    count := 10
    wg := sync.WaitGroup{}

    for i := 0; i < count; i++ {
        wg.Add(1)
        go func(j int) {
            fmt.Print(j)
            wg.Done() // 也可使用 wg.Add(-1)
        }(i)
    }

    wg.Wait()
}

위에서 사용한 주요 내용은 go의 sync 패키지 아래에 있는 waitGroup입니다. 이 역시 직장에서 흔히 사용하는 구현 방식입니다. 요점은 Add 메소드의 위치를 ​​파악하는 것입니다. 그리고 Wait 메소드는 모든 코루틴이 실행될 때까지 기다리는 것입니다

func channel() {
    count := 10 // 最大支持并发
    sum := 100 // 任务总数

    c := make(chan struct{}, count) // 控制任务并发的chan
    sc := make(chan struct{}, sum) // 控制任务总数的chan
    defer close(c)
    defer close(sc)

    for i:=0; i<sum;i++{
        c <- struct{}{} // 作用类似于waitgroup.Add(1)
        go func(j int) {
            fmt.Println(j)
            <- c // 执行完毕，释放资源
            sc <- struct {}{} // 记录到执行总数里
        }(i)
    }

    for i:=sum; i>0;i-- {
        <- sc
    }
}

위의 예에서는 채널 차단 기능을 사용하고 버퍼링된 채널을 사용하여 동시성 수를 제어할 수 있습니다. 예제 메인 프로그램 종료 후 모든 출력이 출력되지 않는 것을 방지하기 위해서만 사용됩니다. 정상 작동 시 프로그램은 일반적으로 차단되므로 제거할 수 있습니다.

더 많은 관련 지식을 알고 싶다면 Go 언어 튜토리얼 칼럼을 주목해주세요

위 내용은 Go 언어의 동시성 수를 제어하는 ​​방법의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!