>백엔드 개발 >Golang >Go에서 고루틴의 실행 순서를 어떻게 제어할 수 있나요?

Go에서 고루틴의 실행 순서를 어떻게 제어할 수 있나요?

Susan Sarandon
Susan Sarandon원래의
2024-12-12 16:54:10866검색

How Can I Control the Execution Order of Goroutines in Go?

고루틴 실행 순서 이해

고루틴 기반 프로그램에서는 고루틴 실행 순서를 예측할 수 없습니다. 이는 고루틴이 동시에 실행되며 언제 어떤 순서로 작업을 완료할지 보장할 수 없기 때문입니다.

다음 코드 조각을 고려하세요.

func sum(a []int, c chan int) {
    fmt.Println("summing: ", a)
    total := 0
    for _, v := range a {
        total += v
    }
    c <- total  // send total to c
}

func main() {
    c := make(chan int)

    go sum([]int{1,2,3}, c)
    go sum([]int{4,5,6}, c)

    x := <-c
    fmt.Println(x)
    x = <-c
    fmt.Println(x)
}

이 예에서는 두 개의 고루틴이 두 정수 조각의 합을 계산하기 위해 시작되었습니다. 그러나 실행 순서와 결과 인쇄 순서는 결정적이지 않습니다. 다음과 같이 출력을 관찰할 수 있습니다.

summing:  [4 5 6]
15
summing:  [1 2 3]
6

또는

summing:  [1 2 3]
6
summing:  [4 5 6]
15

고루틴의 실행 순서를 동기화하기 위해 다양한 접근 방식을 사용할 수 있습니다.

사용 채널 차단:

채널의 차단 특성을 사용하여 강제로 채널을 차단할 수 있습니다. 다음으로 넘어가기 전에 각 고루틴이 완료될 때까지 기다리는 메인 고루틴입니다. 예를 들면 다음과 같습니다.

func main() {

    c := make(chan int)

    go sum([]int{1, 2, 3}, c)

    // Blocks until a value is received
    x := <-c
    fmt.Println(x)

    // Execute the next goroutine
    go sum([]int{4, 5, 6}, c)

    x = <-c
    fmt.Println(x)
}

대기 그룹 사용:

또 다른 일반적인 동기화 기술은 대기 그룹을 사용하는 것입니다. 대기 그룹은 아직 실행 중인 고루틴의 수를 추적하고 더 진행하기 전에 모두 완료될 때까지 기다립니다. 위의 예에서 대기 그룹을 사용할 수 있는 방법은 다음과 같습니다.

func sum(a []int, c chan int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Println("summing: ", a)
    total := 0
    for _, v := range a {
        total += v
    }
    c <- total // send total to c
}

func main() {

    c := make(chan int)
    wg := new(sync.WaitGroup)

    // Increment the wait group
    wg.Add(1)
    // Launch the first goroutine
    go sum([]int{1, 2, 3}, c, wg)

    // Wait for the first goroutine to complete
    wg.Wait()

    // Increment the wait group again
    wg.Add(1)
    // Launch the second goroutine
    go sum([]int{4, 5, 6}, c, wg)

    // Wait for the second goroutine to complete
    wg.Wait()

    // Close the channel to indicate that no more values will be sent
    close(c)

    // Range over the channel to receive the results
    for theSum := range c {
        x := theSum
        fmt.Println(x)
    }

}

동기화 기술을 코드에 통합하면 고루틴이 실행되는 순서를 더 효과적으로 제어할 수 있어 고루틴이 작업을 완료하도록 보장할 수 있습니다. 원하는 순서입니다.

위 내용은 Go에서 고루틴의 실행 순서를 어떻게 제어할 수 있나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.