백엔드 개발 Golang Golang WaitGroup과 코루틴 풀의 효율적인 조합

Golang WaitGroup과 코루틴 풀의 효율적인 조합

Sep 28, 2023 pm 05:22 PM
golang 코루틴 풀 waitgroup

Golang WaitGroup和协程池的高效结合

Golang WaitGroup과 코루틴 풀의 효율적인 조합에는 특정 코드 예제가 필요합니다

소개:
Go 언어는 동시 프로그래밍을 강조하고 코루틴(고루틴)을 통해 효율적인 동시 실행을 달성하는 언어입니다. 여러 작업을 동시에 실행해야 하는 일부 시나리오에서는 WaitGroup과 코루틴 풀을 결합하면 프로그램 실행 효율성과 리소스 활용도를 효과적으로 향상시킬 수 있습니다. 이 기사에서는 효율적인 동시 프로그래밍을 달성하기 위해 Golang에서 WaitGroup 및 코루틴 풀을 사용하는 방법을 소개하고 구체적인 코드 예제를 제공합니다.

1. WaitGroup 소개
WaitGroup은 코루틴 그룹의 실행이 완료되기를 기다리는 데 사용되는 Go 언어 도구입니다. 소스 코드는 다음과 같이 정의됩니다.

type WaitGroup struct {
    noCopy noCopy

    // 64位的值:高32位存储计数器,低32位存储等待计数器
    // 这个变量可以被原子操作加载和存储。
    // 在64位同步原语中,它必须在64位边界对齐。
    // 是一个强制的要求。
    state1 [3]uint32
}
로그인 후 복사

WaitGroup은 일반적으로 메인 고루틴에서 생성되며, 메인 고루틴의 각 하위 고루틴은 Add 메소드를 호출하여 카운터를 늘리고, 실행이 완료된 후 Done 메소드는 다음과 같습니다. 카운터를 감소시키는 데 사용됩니다. 기본 고루틴은 Wait 메서드를 통해 카운터가 0으로 돌아갈 때까지 기다릴 수 있습니다. 구체적인 샘플 코드는 다음과 같습니다.

package main

import (
    "fmt"
    "sync"
)

func main() {
    var wg sync.WaitGroup
    wg.Add(3)

    go func() {
        defer wg.Done()
        fmt.Println("Task 1 executing")
    }()

    go func() {
        defer wg.Done()
        fmt.Println("Task 2 executing")
    }()

    go func() {
        defer wg.Done()
        fmt.Println("Task 3 executing")
    }()

    wg.Wait()
    fmt.Println("All tasks completed")
}
로그인 후 복사

위의 예에서는 WaitGroup 개체를 만든 다음 Add 메서드를 호출하여 카운터를 증가시킵니다. 다음으로 세 개의 하위 고루틴을 생성했으며, 각 고루틴이 실행된 후 Done 메서드를 통해 카운터가 감소합니다. 마지막으로, 메인 고루틴은 Wait 메서드를 호출하여 카운터가 0으로 돌아갈 때까지 기다립니다. 모든 작업이 완료되면 프로그램은 "모든 작업 완료"를 출력합니다.

2. 코루틴 풀 소개
동시 프로그래밍에서 고루틴 풀은 일반적으로 사용되는 모드입니다. 고정된 수의 고루틴을 생성하고 작업을 균등하게 분배함으로써 지속적으로 고루틴을 생성하고 파괴하는 오버헤드를 피할 수 있습니다. Go 언어에서는 채널을 사용하여 코루틴 풀을 구현할 수 있습니다. 구체적인 샘플 코드는 다음과 같습니다.

package main

import (
    "fmt"
    "sync"
)

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        fmt.Println("Worker", id, "started job", j)
        fib := fibonacci(j)
        fmt.Println("Worker", id, "finished job", j)
        results <- fib
    }
}

func fibonacci(n int) int {
    if n <= 1 {
        return n
    }

    return fibonacci(n-1) + fibonacci(n-2)
}

const numJobs = 5
const numWorkers = 3

func main() {
    jobs := make(chan int, numJobs)
    results := make(chan int, numJobs)

    var wg sync.WaitGroup
    wg.Add(numWorkers)

    for w := 1; w <= numWorkers; w++ {
        go func(id int) {
            defer wg.Done()
            worker(id, jobs, results)
        }(w)
    }

    for j := 1; j <= numJobs; j++ {
        jobs <- j
    }
    close(jobs)

    wg.Wait()

    for r := 1; r <= numJobs; r++ {
        fmt.Println(<-results)
    }
}
로그인 후 복사

위의 예에서는 작업 채널에서 보류 중인 작업을 읽은 다음 작업을 실행하고 결과를 결과 채널로 보내는 작업자 함수를 정의했습니다. 작업을 분산하고 결과를 얻어 코루틴 풀의 기능을 구현하기 위해 작업 채널과 결과 채널을 만들었습니다.

주 함수에서는 WaitGroup을 사용하여 모든 작업자(고루틴)가 작업 실행을 완료할 때까지 기다립니다. 그런 다음 실행할 작업을 작업 채널로 보내고 실행 후 채널을 닫습니다. 마지막으로 결과 채널에서 계산 결과를 가져와서 출력합니다.

3. WaitGroup과 코루틴 풀의 효율적인 결합 사례
다음으로, 위의 두 개념을 결합하여 동시 프로그래밍을 구현하기 위해 WaitGroup과 코루틴 풀을 효율적으로 사용하는 방법을 소개하겠습니다. 구체적인 샘플 코드는 다음과 같습니다.

package main

import (
    "fmt"
    "sync"
)

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        fmt.Println("Worker", id, "started job", j)
        fib := fibonacci(j)
        fmt.Println("Worker", id, "finished job", j)
        results <- fib
    }
}

func fibonacci(n int) int {
    if n <= 1 {
        return n
    }

    return fibonacci(n-1) + fibonacci(n-2)
}

const numJobs = 5
const numWorkers = 3

func main() {
    var wg sync.WaitGroup
    wg.Add(numWorkers)

    jobs := make(chan int, numJobs)
    results := make(chan int, numJobs)

    for w := 1; w <= numWorkers; w++ {
        go func(id int) {
            defer wg.Done()
            worker(id, jobs, results)
        }(w)
    }

    for j := 1; j <= numJobs; j++ {
        jobs <- j
    }
    close(jobs)

    go func() {
        wg.Wait()
        close(results)
    }()

    for r := range results {
        fmt.Println(r)
    }
}
로그인 후 복사

위의 예에서는 WaitGroup 개체를 생성하고 Add 메서드를 호출하여 카운터를 증가시켰습니다. 그런 다음 작업을 분배하고 결과를 얻기 위해 작업 채널과 결과 채널을 만들었습니다. 고정된 수의 작업자(고루틴)를 생성하고 Wait 메서드를 사용하여 작업자가 작업을 완료할 때까지 기다립니다.

기본 기능에서는 실행할 작업을 작업 채널로 보내고 실행 후 채널을 닫습니다. 그런 다음 모든 작업자가 작업을 완료할 때까지 기다리고 완료되면 결과 채널을 닫는 코루틴을 시작합니다. 마지막으로 결과 채널에서 계산 결과를 가져와서 출력합니다.

결론:
WaitGroup과 코루틴 풀을 결합하면 동시 프로그래밍을 효율적으로 달성할 수 있습니다. WaitGroup을 사용하여 고루틴 그룹의 실행이 완료될 때까지 기다리면 모든 작업이 완료된 후에도 기본 고루틴이 계속 실행되도록 할 수 있습니다. 코루틴 풀을 사용하면 고루틴을 자주 생성하고 파괴하는 오버헤드를 방지하고 프로그램의 실행 효율성과 리소스 활용도를 향상시킬 수 있습니다.

코드 예제의 피보나치 수열 계산은 단지 데모 예제일 뿐이며 실제 응용 프로그램의 특정 요구에 따라 다른 작업으로 대체될 수 있습니다. WaitGroup과 코루틴 풀을 사용하면 동시에 실행되는 작업 수를 더 효과적으로 제어하고 컴퓨팅 리소스를 효과적으로 활용할 수 있습니다.

Go 언어는 풍부한 동시 프로그래밍 도구와 기능을 제공하지만, 이를 사용할 때는 여전히 주의가 필요합니다. WaitGroup과 코루틴 풀을 적절하게 사용하면 고루틴을 더 잘 관리하고 예약하며 효율적인 동시 프로그래밍을 달성하는 데 도움이 될 수 있습니다.

위 내용은 Golang WaitGroup과 코루틴 풀의 효율적인 조합의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

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

핫 AI 도구

Undresser.AI Undress

Undresser.AI Undress

사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover

AI Clothes Remover

사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool

Undress AI Tool

무료로 이미지를 벗다

Clothoff.io

Clothoff.io

AI 옷 제거제

Video Face Swap

Video Face Swap

완전히 무료인 AI 얼굴 교환 도구를 사용하여 모든 비디오의 얼굴을 쉽게 바꾸세요!

뜨거운 도구

메모장++7.3.1

메모장++7.3.1

사용하기 쉬운 무료 코드 편집기

SublimeText3 중국어 버전

SublimeText3 중국어 버전

중국어 버전, 사용하기 매우 쉽습니다.

스튜디오 13.0.1 보내기

스튜디오 13.0.1 보내기

강력한 PHP 통합 개발 환경

드림위버 CS6

드림위버 CS6

시각적 웹 개발 도구

SublimeText3 Mac 버전

SublimeText3 Mac 버전

신 수준의 코드 편집 소프트웨어(SublimeText3)

Golang을 사용하여 파일을 안전하게 읽고 쓰는 방법은 무엇입니까? Golang을 사용하여 파일을 안전하게 읽고 쓰는 방법은 무엇입니까? Jun 06, 2024 pm 05:14 PM

Go에서는 안전하게 파일을 읽고 쓰는 것이 중요합니다. 지침은 다음과 같습니다. 파일 권한 확인 지연을 사용하여 파일 닫기 파일 경로 유효성 검사 컨텍스트 시간 초과 사용 다음 지침을 따르면 데이터 보안과 애플리케이션의 견고성이 보장됩니다.

Golang 데이터베이스 연결을 위한 연결 풀을 구성하는 방법은 무엇입니까? Golang 데이터베이스 연결을 위한 연결 풀을 구성하는 방법은 무엇입니까? Jun 06, 2024 am 11:21 AM

Go 데이터베이스 연결을 위한 연결 풀링을 구성하는 방법은 무엇입니까? 데이터베이스 연결을 생성하려면 데이터베이스/sql 패키지의 DB 유형을 사용하고, 최대 동시 연결 수를 제어하려면 MaxIdleConns를 설정하고, 연결의 최대 수명 주기를 제어하려면 ConnMaxLifetime을 설정하세요.

JSON 데이터를 Golang의 데이터베이스에 저장하는 방법은 무엇입니까? JSON 데이터를 Golang의 데이터베이스에 저장하는 방법은 무엇입니까? Jun 06, 2024 am 11:24 AM

JSON 데이터는 gjson 라이브러리 또는 json.Unmarshal 함수를 사용하여 MySQL 데이터베이스에 저장할 수 있습니다. gjson 라이브러리는 JSON 필드를 구문 분석하는 편리한 방법을 제공하며, json.Unmarshal 함수에는 JSON 데이터를 비정렬화하기 위한 대상 유형 포인터가 필요합니다. 두 방법 모두 SQL 문을 준비하고 삽입 작업을 수행하여 데이터를 데이터베이스에 유지해야 합니다.

Golang 프레임워크 vs. Go 프레임워크: 내부 아키텍처와 외부 기능 비교 Golang 프레임워크 vs. Go 프레임워크: 내부 아키텍처와 외부 기능 비교 Jun 06, 2024 pm 12:37 PM

GoLang 프레임워크와 Go 프레임워크의 차이점은 내부 아키텍처와 외부 기능에 반영됩니다. GoLang 프레임워크는 Go 표준 라이브러리를 기반으로 하며 기능을 확장하는 반면, Go 프레임워크는 특정 목적을 달성하기 위해 독립적인 라이브러리로 구성됩니다. GoLang 프레임워크는 더 유연하고 Go 프레임워크는 사용하기 더 쉽습니다. GoLang 프레임워크는 성능 면에서 약간의 이점이 있고 Go 프레임워크는 확장성이 더 좋습니다. 사례: gin-gonic(Go 프레임워크)은 REST API를 구축하는 데 사용되고 Echo(GoLang 프레임워크)는 웹 애플리케이션을 구축하는 데 사용됩니다.

Golang 정규 표현식과 일치하는 첫 번째 하위 문자열을 찾는 방법은 무엇입니까? Golang 정규 표현식과 일치하는 첫 번째 하위 문자열을 찾는 방법은 무엇입니까? Jun 06, 2024 am 10:51 AM

FindStringSubmatch 함수는 정규 표현식과 일치하는 첫 번째 하위 문자열을 찾습니다. 이 함수는 일치하는 하위 문자열이 포함된 조각을 반환합니다. 첫 번째 요소는 전체 일치 문자열이고 후속 요소는 개별 하위 문자열입니다. 코드 예: regexp.FindStringSubmatch(text,pattern)는 일치하는 하위 문자열의 조각을 반환합니다. 실제 사례: 이메일 주소의 도메인 이름을 일치시키는 데 사용할 수 있습니다. 예를 들어 이메일:="user@example.com", 패턴:=@([^\s]+)$를 사용하여 도메인 이름 일치를 가져옵니다. [1].

프론트 엔드에서 백엔드 개발로 전환하면 Java 또는 Golang을 배우는 것이 더 유망합니까? 프론트 엔드에서 백엔드 개발로 전환하면 Java 또는 Golang을 배우는 것이 더 유망합니까? Apr 02, 2025 am 09:12 AM

백엔드 학습 경로 : 프론트 엔드에서 백엔드 초보자로서 프론트 엔드에서 백엔드까지의 탐사 여행은 프론트 엔드 개발에서 변화하는 백엔드 초보자로서 이미 Nodejs의 기초를 가지고 있습니다.

Golang에서 미리 정의된 시간대를 사용하는 방법은 무엇입니까? Golang에서 미리 정의된 시간대를 사용하는 방법은 무엇입니까? Jun 06, 2024 pm 01:02 PM

Go에서 미리 정의된 시간대를 사용하는 단계는 다음과 같습니다. "time" 패키지를 가져옵니다. LoadLocation 함수를 통해 특정 시간대를 로드합니다. Time 객체 생성, 시간 문자열 구문 분석, 날짜 및 시간 변환 수행 등의 작업에 로드된 시간대를 사용합니다. 미리 정의된 시간대 기능의 적용을 설명하기 위해 다양한 시간대를 사용하여 날짜를 비교합니다.

Golang 프레임워크 개발 실습 튜토리얼: FAQ Golang 프레임워크 개발 실습 튜토리얼: FAQ Jun 06, 2024 am 11:02 AM

Go 프레임워크 개발 FAQ: 프레임워크 선택: Gin(API), Echo(확장 가능), Beego(ORM), Iris(성능) 등 애플리케이션 요구 사항 및 개발자 선호도에 따라 다릅니다. 설치 및 사용: gomod 명령을 사용하여 프레임워크를 설치하고 가져와서 사용합니다. 데이터베이스 상호 작용: gorm과 같은 ORM 라이브러리를 사용하여 데이터베이스 연결 및 작업을 설정합니다. 인증 및 권한 부여: gin-contrib/sessions와 같은 세션 관리 및 인증 미들웨어를 사용합니다. 실제 사례: Gin 프레임워크를 사용하여 POST, GET 및 기타 기능을 제공하는 간단한 블로그 API를 구축합니다.

See all articles