我试过Go Tour
exercise #71
如果它运行像go run 71_hang.go ok,它运行正常.
但是,如果你使用go run 71_hang.go nogood,它将永远运行.
唯一的区别是select语句中默认的额外fmt.Print(“”).
我不确定,但我怀疑某种无限循环和竞争条件?这是我的解决方案.
注意:Go没有抛出并不是死锁:所有的goroutines都睡着了 – 僵局!
package main import ( "fmt" "os" ) type Fetcher interface { // Fetch returns the body of URL and // a slice of URLs found on that page. Fetch(url string) (body string,urls []string,err error) } func crawl(todo Todo,fetcher Fetcher,todoList chan Todo,done chan bool) { body,urls,err := fetcher.Fetch(todo.url) if err != nil { fmt.Println(err) } else { fmt.Printf("found: %s %q\n",todo.url,body) for _,u := range urls { todoList <- Todo{u,todo.depth - 1} } } done <- true return } type Todo struct { url string depth int } // Crawl uses fetcher to recursively crawl // pages starting with url,to a maximum of depth. func Crawl(url string,depth int,fetcher Fetcher) { visited := make(map[string]bool) doneCrawling := make(chan bool,100) toDoList := make(chan Todo,100) toDoList <- Todo{url,depth} crawling := 0 for { select { case todo := <-toDoList: if todo.depth > 0 && !visited[todo.url] { crawling++ visited[todo.url] = true go crawl(todo,fetcher,toDoList,doneCrawling) } case <-doneCrawling: crawling-- default: if os.Args[1]=="ok" { // * fmt.Print("") } if crawling == 0 { goto END } } } END: return } func main() { Crawl("http://golang.org/",4,fetcher) } // fakeFetcher is Fetcher that returns canned results. type fakeFetcher map[string]*fakeResult type fakeResult struct { body string urls []string } func (f *fakeFetcher) Fetch(url string) (string,[]string,error) { if res,ok := (*f)[url]; ok { return res.body,res.urls,nil } return "",nil,fmt.Errorf("not found: %s",url) } // fetcher is a populated fakeFetcher. var fetcher = &fakeFetcher{ "http://golang.org/": &fakeResult{ "The Go Programming Language",[]string{ "http://golang.org/pkg/","http://golang.org/cmd/",},"http://golang.org/pkg/": &fakeResult{ "Packages",[]string{ "http://golang.org/","http://golang.org/pkg/fmt/","http://golang.org/pkg/os/","http://golang.org/pkg/fmt/": &fakeResult{ "Package fmt","http://golang.org/pkg/","http://golang.org/pkg/os/": &fakeResult{ "Package os",}
在select中添加默认语句会改变select的工作方式.如果没有默认语句,select将阻止等待通道上的任何消息.使用默认语句select会在每次从通道中读取任何内容时运行默认语句.在你的代码中,我认为这是一个无限循环.将fmt.Print语句放入允许调度程序安排其他goroutine.
原文链接:https://www.f2er.com/go/187018.html如果您更改这样的代码,那么它可以正常工作,使用非阻塞方式选择,允许其他goroutine正常运行.
for { select { case todo := <-toDoList: if todo.depth > 0 && !visited[todo.url] { crawling++ visited[todo.url] = true go crawl(todo,doneCrawling) } case <-doneCrawling: crawling-- } if crawling == 0 { break } }
如果使用GOMAXPROCS = 2,则可以使原始代码生效,这是调度程序在无限循环中忙碌的另一个提示.
请注意,goroutines是合作安排的.我不完全了解你的问题是选择是goroutine应该产生的一个点 – 我希望其他人可以解释为什么它不在你的例子中.