>백엔드 개발 >Golang >sync.WaitGroup을 사용하여 모든 고루틴을 실행하는 방법은 무엇입니까?

sync.WaitGroup을 사용하여 모든 고루틴을 실행하는 방법은 무엇입니까?

PHPz
PHPz앞으로
2024-02-09 11:40:09777검색

sync.WaitGroup을 사용하여 모든 고루틴을 실행하는 방법은 무엇입니까?

PHP 편집기 Apple은 모든 고루틴을 실행하는 실용적인 방법인 sync.WaitGroup을 소개합니다. Go 언어에서 고루틴은 동시에 여러 작업을 수행할 수 있는 경량 스레드입니다. 그러나 다음 단계로 진행하기 전에 모든 고루틴이 완료될 때까지 기다려야 하는 경우도 있습니다. 이때 sync.WaitGroup이 유용합니다. 모든 고루틴이 완료될 때까지 기다리는 간단하고 효과적인 방법을 제공하여 프로그램의 올바른 실행 순서를 보장합니다. 다음에는 sync.WaitGroup을 사용하여 이 기능을 구현하는 방법을 자세히 소개하겠습니다.

질문 내용

현재 모든 값을 채널에 푸시하고 읽어서 제곱을 계산하고 있습니다. time.sleep(2000 * time.millisecond)를 사용하면 2초 동안 실행이 차단되므로 대신 각 고루틴을 처리하고 실행을 기다린 다음 프로그램을 종료하도록 합니다. 방금 golang에서 벗어났으므로 이제 다음과 같은 기본적인 질문을 하게 됩니다. :(. 누구든지 이 문제를 해결하도록 도와줄 수 있나요?

package main

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

func doSquare(num int) int {
    return num * num
}

var wg sync.WaitGroup

func main() {

    wg.Add(1)
    st := []int{1, 2, 3, 4, 5, 6, 7, 8, 9, 10}
    quit := make(chan bool)
    ch := make(chan int)
    go func() {
        for i := range st {
            ch <- i
        }
    }()

    go func() {
        for {
            select {
            case x := <-ch:
                fmt.Println(doSquare(x))
                // return

            case <-quit:
                wg.Done()
            default:
                // fmt.Println("---")
                // do something
            }
        }
    }()

    quit <- true

    wg.Wait()
    time.Sleep(2000 * time.Millisecond)
}

Solution

첫 번째 고루틴의 끝으로 qui​​t 이동하세요

으아악

이것은 close(ch)더 이상 데이터가 없다는 또 다른 표현입니다

으아악

위 내용은 sync.WaitGroup을 사용하여 모든 고루틴을 실행하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
이 기사는 stackoverflow.com에서 복제됩니다. 침해가 있는 경우 admin@php.cn으로 문의하시기 바랍니다. 삭제