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

PHPz
풀어 주다: 2024-02-09 11:40:09
앞으로
751명이 탐색했습니다.

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으로 문의하세요.
최신 이슈
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿
회사 소개 부인 성명 Sitemap
PHP 중국어 웹사이트:공공복지 온라인 PHP 교육,PHP 학습자의 빠른 성장을 도와주세요!