동시 프로그래밍 영역에서 고루틴과 채널은 비동기 통신 패턴을 구현하는 데 중추적인 역할을 합니다. 그러나 시간 초과와 상호 작용하는 방식을 이해하는 것은 약간 까다로울 수 있습니다.
다음 코드 조각을 고려하세요.
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 중국어 웹사이트의 기타 관련 기사를 참조하세요!