Go의 Select 문에서 채널의 우선순위를 어떻게 지정할 수 있나요?

Go의 Select 문에서 우선순위 구현

Go의 select 문을 사용하면 고루틴이 여러 채널에서 멀티플렉싱하여 먼저 준비된 채널의 데이터를 처리할 수 있습니다. . 그러나 기본적으로 채널 우선순위 지정을 지원하지 않습니다. 이 문서에서는 select 문 내에서 특정 채널을 다른 채널보다 우선순위를 지정하려는 일반적인 프로그래밍 시나리오를 살펴봅니다.

제공된 예에서 고루틴은 데이터를 두 채널(out 및exit)로 보냅니다. 처음에는 두 채널이 모두 비어 있지만 종료를 처리하기 전에 모든 값이 처리되도록 우선순위를 지정하는 것이 목적입니다. 질문에서 볼 수 있듯이 표준 select 문을 사용하면 원하는 동작을 얻을 수 없습니다.

이 문제를 해결하기 위해 Go는 우아한 솔루션을 제공합니다. select에 내장된 우선순위에 의존하는 대신 우선순위를 지정해야 하는 채널(이 경우 종료)은 발신자 고루틴에서만 액세스할 수 있어야 합니다. 송신자 고루틴이 종료할 준비가 되면 채널을 닫습니다. 범위 기반 루프를 사용하여 채널(x := 범위 값의 경우)을 반복하는 수신기 고루틴은 채널이 닫힐 때까지 계속 데이터를 처리합니다.

이 솔루션을 구현하면 다음 코드가 생성됩니다.

package main

import (
    "fmt"
    "math/rand"
    "time"
)

var (
    produced  = 0
    processed = 0
)

func produceEndlessly(vals chan int, quit chan bool) {
    defer close(vals)
    for {
        select {
        case vals <- rand.Int():
            produced++
        case <-quit:
            return
        }
    }
}

func quitRandomly(quit chan bool) {
    d := time.Duration(rand.Int63n(5e9))
    fmt.Println("SLEEP", d)
    time.Sleep(d)
    fmt.Println("SEND QUIT")
    quit <- true
}

func main() {
    vals, quit := make(chan int, 10), make(chan bool)
    go produceEndlessly(vals, quit)
    go quitRandomly(quit)
    for x := range vals {
        fmt.Println(x)
        processed++
        time.Sleep(time.Duration(rand.Int63n(5e8)))
    }
    fmt.Println("Produced:", produced)
    fmt.Println("Processed:", processed)
}

이 업데이트된 코드에서 종료 채널은 발신자 고루틴에서만 전달됩니다. 이렇게 하면 보낸 사람이 종료할 준비가 될 때까지 종료가 선택되지 않습니다. 결과적으로, 수신자 고루틴은 종료를 처리하기 전에 vals의 모든 데이터를 소진합니다.

위 내용은 Go의 Select 문에서 채널의 우선순위를 어떻게 지정할 수 있나요?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!