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

Go Select 문의 우선순위

Go의 select 문을 사용하여 여러 채널로 작업할 때 채널 처리 순서가 보장되지 않습니다. 한 채널을 다른 채널보다 우선순위를 지정하려면 해결 방법을 사용할 수 있습니다.

문제 설명

아래 코드 조각에서 목표는 출력 채널의 모든 값이 종료 채널 이전에 처리됩니다.

package main

import "fmt"

func sender(out chan int, exit chan bool){
    for i := 1; i <= 10; i++ {
        out <- i
    }
    exit <- true
}

func main(){
    out := make(chan int, 10)
    exit := make(chan bool)

    go sender(out, exit)

    L:
    for {
        select {
            case i := <-out:
                fmt.Printf("Value: %d\n", i)
            case <-exit:
                fmt.Println("Exiting")
                break L
        }
    }
    fmt.Println("Did we get all 10? Most likely not")
}

그러나 select 문을 사용하면 한 채널에 대한 우선순위가 제공되지 않습니다.

솔루션: 모국어 지원

Go는 기본적으로 "quit" 채널의 가시성을 제작자에게만 제한하여 select 문에서 채널 우선순위 지정을 지원합니다. 제작자가 종료하기로 결정하면 채널을 닫습니다. 소비자는 채널이 비어 있고 닫힌 경우에만 종료됩니다.

package main

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

var (
    produced  = 0
    processed = 0
)

func produceEndlessly(out chan int, quit chan bool) {
    defer close(out)
    for {
        select {
        case <-quit:
            fmt.Println("RECV QUIT")
            return
        default:
            out <- rand.Int()
            time.Sleep(time.Duration(rand.Int63n(5e6)))
            produced++
        }
    }
}

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)
}

이 예에서 종료 채널은 생산자 기능(produceEndously)에만 표시됩니다. 제작자는 일정 시간이 지난 후 무작위로 그만 두기로 결정합니다. 소비자 함수(main)는 닫히고 비어 있을 때까지 vals 채널을 반복합니다. 생산자의 "종료" 메시지에 우선순위를 부여함으로써 프로그램이 종료되기 전에 vals 채널의 모든 값이 처리됩니다.

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