동시 프로그래밍 가이드: Golang 표준 라이브러리의 병렬성 탐색-Golang-php.cn

동시 프로그래밍 가이드: Golang 표준 라이브러리의 병렬성 탐색

WBOY

풀어 주다： 2024-01-20 09:08:12

원래의

1151명이 탐색했습니다.

동시 프로그래밍 가이드: Golang 표준 라이브러리의 병렬성 탐색

Golang 표준 라이브러리의 동시 프로그래밍 가이드

소개:
동시 프로그래밍은 프로그램 성능 문제를 해결하고 컴퓨팅 리소스를 효율적으로 사용하는 중요한 수단입니다. Golang 프로그래밍 언어에서는 다양한 동시 프로그래밍 도구와 방법이 제공됩니다. 이 기사에서는 Golang 표준 라이브러리의 몇 가지 일반적인 동시 프로그래밍 기술을 소개하고 특정 코드 예제를 통해 사용법과 예방 조치를 설명합니다.

고루틴(코루틴)
고루틴은 Go 키워드로 시작되는 Golang의 경량 스레드입니다. 고루틴을 통해 프로그램 내에서 동시에 여러 작업을 실행할 수 있어 높은 동시 실행 효과를 얻을 수 있습니다. 다음은 간단한 고루틴 예시입니다:

package main

import (
    "fmt"
    "time"
)

func printNumbers() {
    for i := 0; i < 5; i++ {
        fmt.Printf("%d ", i)
        time.Sleep(time.Millisecond * 500)
    }
}

func printLetters() {
    for i := 'A'; i < 'F'; i++ {
        fmt.Printf("%c ", i)
        time.Sleep(time.Millisecond * 500)
    }
}

func main() {
    go printNumbers()    // 启动一个Goroutine，打印数字
    go printLetters()    // 启动另一个Goroutine，打印字母

    time.Sleep(time.Second * 3)    // 等待两个Goroutine执行完毕
    fmt.Println("Done")
}

로그인 후 복사

위 코드에서 우리는 각각 printNumbers와 printLetters 두 함수를 정의하고 go를 전달했습니다. code> 키워드는 각각 두 개의 고루틴으로 시작합니다. time.Sleep 함수를 사용하여 두 고루틴의 실행이 완료될 때까지 기다리면 출력 결과에 숫자와 문자가 번갈아 출력되는 것을 볼 수 있습니다. printNumbers和printLetters两个函数，并通过go关键字将它们分别启动为两个Goroutine。通过time.Sleep函数等待两个Goroutine执行完毕，可以看到输出结果中数字和字母是交替输出的。

Channel（通道）
在Golang中，Goroutine之间的通信使用Channel（通道）来完成。Channel是一种类型安全的队列，用于在Goroutine之间传递数据。下面是一个简单的Channel示例：

package main

import (
    "fmt"
    "time"
)

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

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

    numWorkers := 3
    for w := 1; w <= numWorkers; w++ {
        go worker(w, jobs, results)
    }

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

    for a := 1; a <= numJobs; a++ {
        result := <-results
        fmt.Println("Result:", result)
    }
}

로그인 후 복사

在上述代码中，我们定义了worker函数，该函数用于接收jobs通道传入的数字，并进行相应的处理，结果通过results通道返回。在主函数中，我们分别创建了jobs和results两个通道，并将jobs通道传递给三个Goroutine执行。然后，通过for循环向jobs通道发送5个作业，并关闭通道。最后，通过for循环接收results通道的返回结果并输出。

WaitGroup（等待组）
在并发编程中，经常需要等待多个Goroutine的全部执行完成后再进行下一步的操作。Golang中的sync包提供了WaitGroup类型来实现这个功能。下面是一个使用WaitGroup的示例：

package main

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

func worker(id int, wg *sync.WaitGroup) {
    defer wg.Done()
    fmt.Printf("Worker %d starting
", id)
    time.Sleep(time.Second)
    fmt.Printf("Worker %d done
", id)
}

func main() {
    var wg sync.WaitGroup

    numWorkers := 3
    wg.Add(numWorkers)
    for w := 1; w <= numWorkers; w++ {
        go worker(w, &wg)
    }

    wg.Wait()
    fmt.Println("All workers done")
}

로그인 후 복사

在上述代码中，我们定义了worker函数，该函数接收一个WaitGroup参数，执行相应的任务，并在任务执行完成后通过Done方法通知WaitGroup。在主函数中，我们创建了一个WaitGroup变量，并通过Add方法指定需要等待的Goroutine数量。然后，使用go关键字启动相应数量的Goroutine，并将WaitGroup指针传递给每个Goroutine。最后，通过Wait

Golang에서는 고루틴간의 통신은 Channel을 통해 완성됩니다. 채널은 고루틴 간에 데이터를 전달하는 데 사용되는 유형 안전 대기열입니다. 다음은 간단한 채널 예입니다.

worker

sync

Add

go

Wait

위 내용은 동시 프로그래밍 가이드: Golang 표준 라이브러리의 병렬성 탐색의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!