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

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

PHPz

풀어 주다： 2024-02-09 11:40:09

앞으로

773명이 탐색했습니다.

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)
}

로그인 후 복사