고루틴을 사용할 때 Go 채널에서 시간 초과가 실패하는 이유는 무엇입니까?

Mary-Kate Olsen
풀어 주다: 2024-11-09 00:21:01
원래의
751명이 탐색했습니다.

Why Does Timeout Fail in Go Channels When Using Goroutines?

Go에서 채널과 함께 시간 초과 사용

동시 프로그래밍 영역에서 고루틴과 채널은 비동기 통신 패턴을 구현하는 데 중추적인 역할을 합니다. 그러나 시간 초과와 상호 작용하는 방식을 이해하는 것은 약간 까다로울 수 있습니다.

다음 코드 조각을 고려하세요.

import "fmt"
import "time"

func check(u string) bool {
    time.Sleep(4 * time.Second)
    return true
}

func IsReachable(urls []string) bool {
    ch := make(chan bool, 1)
    for _, url := range urls {
        go func(u string) {
            select {
            case ch <- check(u):
            case <-time.After(time.Second):
                ch <- false
            }
        }(url)
    }
    return <-ch
}

func main() {
    fmt.Println(IsReachable([]string{"url1"}))
}
로그인 후 복사

이 코드의 목표는 URL 목록에 연결할 수 있는지 확인하는 것입니다. . 그러나 연결할 수 없는 URL이 있는지 여부에 관계없이 항상 true를 반환합니다. 타임아웃 사례가 실행되지 않는 이유는 무엇입니까?

이 문제를 이해하는 열쇠는 고루틴과 채널이 상호 작용하는 방식에 있습니다. 외부 고루틴에서 check(u)가 호출되면 해당 고루틴의 실행을 4초 동안 일시 중지합니다. 그러나 select 문은 check(u)가 반환된 후에만 실행됩니다. 그 때까지 check(u)와 시간이 모두 실행됩니다. 브랜치가 실행될 준비가 된 후입니다.

이 문제를 해결하려면 자체 고루틴 내에서 check(u)를 격리해야 합니다.

import "fmt"
import "time"

func check(u string, checked chan<- bool) {
    time.Sleep(4 * time.Second)
    checked <- true
}

func IsReachable(urls []string) bool {
    ch := make(chan bool, 1)
    for _, url := range urls {
        go func(u string) {
            checked := make(chan bool)
            go check(u, checked)
            select {
            case ret := <-checked:
                ch <- ret
            case <-time.After(1 * time.Second):
                ch <- false
            }
        }(url)
    }
    return <-ch
}

func main() {
    fmt.Println(IsReachable([]string{"url1"}))
}
로그인 후 복사

이 수정된 코드에서는 check(u)가 별도의 고루틴에서 호출됩니다. 이를 통해 select 문이 check(u) 완료와 시간 초과 조건을 적절하게 구분할 수 있습니다.

또는 모든 URL에 대해 단일 시간 초과를 사용하여 코드를 단순화할 수 있습니다.

import "fmt"
import "time"

func check(u string, ch chan<- bool) {
    time.Sleep(4 * time.Second)
    ch <- true
}

func IsReachable(urls []string) bool {
    ch := make(chan bool, len(urls))
    for _, url := range urls {
        go check(url, ch)
    }
    time.AfterFunc(time.Second, func() { ch <- false })
    return <-ch
}

func main() {
    fmt.Println(IsReachable([]string{"url1", "url2"}))
}
로그인 후 복사

이 버전에서는 모든 응답을 담을 수 있는 채널을 사용합니다. 시간 초과는 1초로 설정되며 채널에 도착하는 첫 번째 결과가 반환됩니다. 제한 시간이 만료되기 전에 연결할 수 있는 URL이 없으면 채널은 잘못된 값을 받게 됩니다.

위 내용은 고루틴을 사용할 때 Go 채널에서 시간 초과가 실패하는 이유는 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

원천:php.cn
본 웹사이트의 성명
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.
저자별 최신 기사
인기 튜토리얼
더>
최신 다운로드
더>
웹 효과
웹사이트 소스 코드
웹사이트 자료
프론트엔드 템플릿