대규모 프로젝트에 Golang 기능 동시 프로그래밍 적용-Golang-php.cn

대규모 프로젝트에 Golang 기능 동시 프로그래밍 적용

WBOY

풀어 주다： 2024-04-17 14:12:01

원래의

1018명이 탐색했습니다.

동시 프로그래밍은 대규모 Go 프로젝트의 성능과 확장성을 향상시킬 수 있습니다. 1. 동시성 본래의 가치: 고루틴은 경량 스레드이고, 채널은 데이터를 안전하게 전송하기 위한 버퍼입니다. 2. 동시성 모드: 파이프라인 동시성은 생산자-소비자 모델에서 사용됩니다. 작업 풀은 작업 실행을 기다리는 고정된 수의 고루틴을 유지합니다. 3. 실제 사례: 전자 상거래 백엔드 서비스는 파이프라인을 사용하여 주문을 동시에 처리하고 작업 풀을 사용하여 데이터베이스 연결을 최적화합니다.

대규모 프로젝트에 Golang 기능 동시 프로그래밍 적용

대규모 프로젝트에서 Go 기능적 동시 프로그래밍 적용

개요

대규모 Go 프로젝트에서 동시 프로그래밍을 최대한 활용하면 성능과 확장성을 크게 향상시킬 수 있습니다. Go에 내장된 동시성 메커니즘은 효율적인 병렬 코드를 작성하기 위한 강력한 도구를 제공합니다.

동시성 프리미티브

goroutines는 전체 프로세스를 잠그지 않고 코드를 실행할 수 있는 Go의 경량 스레드입니다. 고루틴을 생성하려면 go 키워드를 사용하세요.

go func() {
    // 并发执行的代码
}

로그인 후 복사

channel은 고루틴 간에 데이터를 안전하게 전달하는 데 사용되는 버퍼입니다. 채널에는 데이터 유형 안전성을 보장하는 유형이 있습니다:

var dataChannel chan int
func main() {
    dataChannel = make(chan int)
    go sendData(dataChannel)
    receivedData := <-dataChannel
    fmt.Println("Received data:", receivedData)
}

func sendData(ch chan int) {
    ch <- 42 // 发送数据
}

로그인 후 복사

동시성 모드

파이프라인 동시성 파이프를 사용하여 한 고루틴에서 다른 고루틴으로 데이터를 전달함으로써 파이프라인 내에서 생산자 및 소비자 모델을 구현합니다.

func pipeExample() {
    numJobs := 1000

    input := make(chan int)
    processed := make(chan int)

    // 启动一个 goroutine 表示消费者
    go func() {
        for {
            select {
            case job := <-input:
                processedData := process(job)
                processed <- processedData
            }
        }
    }()

    // 启动多个 goroutine 表示生产者
    for i := 0; i < numJobs; i++ {
        go func(i int) {
            input <- i
        }(i)
    }

    close(input) // 当所有工作都完成时关闭输入通道

    // 等待所有工作处理完成
    for i := 0; i < numJobs; i++ {
        _ = <-processed
    }
}

로그인 후 복사

작업 풀 이 유지 관리합니다. 작업 실행을 기다리는 고정된 개수의 고루틴:

func workerPoolExample() {
    jobs := make(chan int)
    results := make(chan int)

    // 启动一个 goroutine 表示工作池中的每一个 worker
    for w := 1; w <= numWorkers; w++ {
        go worker(jobs, results)
    }

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

    for a := 1; a <= numJobs; a++ {
        _ = <-results // 等待接收所有结果
    }
}

func worker(jobs <-chan int, results chan<- int) {
    for j := range jobs {
        result := process(j)
        results <- result
    }
}

로그인 후 복사