golang의 병렬 쓰기 방법은 무엇입니까?

현대 소프트웨어 개발에서는 컴퓨터 하드웨어 리소스를 효율적으로 사용하는 것이 중요합니다. 병렬 프로그래밍은 멀티 코어 CPU의 활용을 극대화할 수 있는 프로그래밍 방법입니다. 다른 프로그래밍 언어와 비교하여 Go 언어(Golang이라고도 함)에는 동시 프로그래밍을 지원하는 도구와 메커니즘이 내장되어 있어 병렬 프로그래밍 분야에서 널리 사용되고 인정받고 있습니다.

이 글에서는 Golang에서 병렬 프로그래밍을 구현하는 몇 가지 방법과 기술, 그리고 적용 가능한 시나리오와 예방 조치를 소개합니다.

1. 고루틴과 채널

고루틴은 Golang이 다른 프로그래밍 언어에서 차용한 병렬 프로그래밍 모델입니다. 경량 스레드로 알려진 이 스레드는 컴퓨터의 멀티 코어 처리 능력을 보다 효율적으로 사용합니다. 각 고루틴은 Golang의 런타임 시스템에 의해 자동으로 관리되며 개발자는 go 키워드를 실행하여 고루틴을 생성하기만 하면 됩니다.

예:

func main() {
    go func() {
        fmt.Println("Hello, Goroutine!")
    }()
    fmt.Println("Hello, World!")
}

이 코드에서는 익명 함수를 생성하고 go 키워드를 사용하여 이를 고루틴으로 변환합니다. 프로그램은 "Hello, World!"와 "Hello, Goroutine!"을 동시에 출력합니다.

채널은 고루틴 간의 통신을 위한 Golang의 메커니즘입니다. 채널은 모든 유형의 데이터를 전송하는 데 사용될 수 있으므로 데이터 및 제어 정보는 서로 다른 고루틴 간에 전달될 수 있습니다.

예:

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        fmt.Println("worker", id, "started  job", j)
        time.Sleep(time.Second)
        fmt.Println("worker", id, "finished job", j)
        results <- j * 2
    }
}

func main() {
    jobs := make(chan int, 100)
    results := make(chan int, 100)
    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }
    for j := 1; j <= 9; j++ {
        jobs <- j
    }
    close(jobs)
    for a := 1; a <= 9; a++ {
        <-results
    }
}

이 코드에서는 두 개의 채널(작업 수신용 채널과 작업 결과 반환용 채널)을 수신하는 작업자 함수를 정의합니다. 우리는 세 개의 고루틴을 만들었습니다. 각 고루틴은 작업 채널에서 작업을 가져오고 처리 결과를 결과 채널에 씁니다. 마지막으로 for 루프를 사용하여 9개의 작업을 작업 채널로 보내고 결과 채널의 값을 표준 출력으로 출력합니다. 작업자 함수가 종료되도록 for 루프 후에 작업 채널을 닫아야 합니다.

2. 동기화 패키지

Golang에서 동기화 패키지는 다음과 같은 병렬 프로그래밍에 필요한 몇 가지 동기화 도구를 제공합니다.

· WaitGroup: 고루틴 그룹이 작업을 완료할 때까지 기다립니다.
· Mutex: 공유된 항목의 상호 배제를 구현합니다. 데이터 액세스
· Cond: 조건 변수, 여러 고루틴 간의 통신 및 동기화에 사용됩니다.

여기에서는 WaitGroup을 사용하는 예를 보여줍니다.

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("Worker %d starting\n", id)

    time.Sleep(time.Second)
    fmt.Printf("Worker %d done\n", id)
}

func main() {
    var wg sync.WaitGroup

    for i := 1; i <= 5; i++ {
        wg.Add(1)
        go worker(i, &wg)
    }

    wg.Wait()
}

이 예에서는 WaitGroup 포인터를 매개변수로 받는 작업자 함수를 정의합니다. 함수 작업이 완료된 후 WaitGroup의 Done 메서드를 호출하여 해당 함수가 속한 Goroutine 작업이 완료되었음을 알립니다. 기본 기능에서는 각 작업자 기능에 대한 고루틴을 만들고 WaitGroup의 Add 메서드를 사용하여 여기에서 실행 중인 고루틴 그룹이 있음을 WaitGroup에 알립니다. 마지막으로 모든 고루틴이 작업을 완료할 때까지 기다리기 위해 Wait 메서드를 호출합니다.

3. GOMAXPROCS 설정

Golang에서 GOMAXPROCS는 동시에 실행되어야 하는 고루틴 수를 나타내는 숫자입니다. 이 숫자를 너무 작게 설정하면 프로그램의 병렬성이 제한됩니다. 너무 크게 설정하면 컴퓨터 리소스가 낭비됩니다. 따라서 컴퓨터 리소스의 과도한 활용 또는 과소 활용을 방지하려면 컴퓨터의 프로세서 코어 수에 따라 GOMAXPROCS의 값을 설정해야 합니다.

기본적으로 Golang의 GOMAXPROCS는 프로세서 코어 수와 동일합니다. 런타임 패키지를 사용하여 프로그램 코드에서 수정할 수 있습니다.

import "runtime"

//...

func main() {
    numCPU := runtime.NumCPU()
    runtime.GOMAXPROCS(numCPU)

    //...
}

여기에서는 런타임 패키지를 사용하여 프로세서 코어 수를 얻은 다음 GOMAXPROCS 값을 코어 수와 동일하게 설정하십시오.

요약

이 기사에서는 고루틴 및 채널, 동기화 패키지, GOMAXPROCS 설정을 포함하여 Golang에서 동시 프로그래밍하는 여러 방법과 기법을 소개합니다. 동시 프로그래밍은 프로그램 성능과 효율성을 향상시킬 수 있지만 일부 위험과 과제도 수반합니다. 따라서 동시 프로그래밍을 수행할 때 실제 상황에 따라 적절한 솔루션을 선택하고, 불필요한 오류와 자원 낭비를 피하기 위해 병렬성 정도를 제어하는 ​​데 주의를 기울여야 합니다.

위 내용은 golang의 병렬 쓰기 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!