Goroutine 使用通道奇怪的结果
当我运行 goroutines 时，我通常得到 40 作为值，我知道它的并发性，但为什么最后一个数字来了？我想输出必须是：
Page number: 34
Page number: 12
Page number: 8
Page number: 2
Page number: 29
示例源代码：
package main
import (
"fmt"
"io/ioutil"
"net/http"
)
func getWebPageContent(url string, c chan int, val int) interface{} {
if r, err := http.Get(url); err == nil {
defer r.Body.Close()
if body, err := ioutil.ReadAll(r.Body); err == nil {
c <- val
return string(body)
}
} else {
fmt.Println(err)
}
return "XoX"
}
const MAX_TH = 40
func main() {
// pln := fmt.Println
messages := make(chan int)
for j := 0; j < MAX_TH; j++ {
go func() { getWebPageContent("http://www.example.com", messages, j) }()
}
routine_count := 0
var page_number int
for {
page_number = <-messages
routine_count++
fmt.Println("Page number: ", page_number)
if routine_count == MAX_TH {
break
}
}
close(messages)
}
开满天机2回答
-
慕无忌1623718
闭包作为 goroutine 运行会发生什么？在并发使用闭包时可能会出现一些混淆。考虑以下程序：func main() { done := make(chan bool) values := []string{"a", "b", "c"} for _, v := range values { go func() { fmt.Println(v) done <- true }() } // wait for all goroutines to complete before exiting for _ = range values { <-done }}人们可能会错误地期望看到 a、b、c 作为输出。你可能会看到的是 c、c、c。这是因为循环的每次迭代都使用变量 v 的相同实例，因此每个闭包共享该单个变量。当闭包运行时，它会打印 fmt.Println 执行时 v 的值，但 v 可能在 goroutine 启动后被修改。为了帮助在这些问题和其他问题发生之前检测它们，请运行 go vet。要在启动时将 v 的当前值绑定到每个闭包，必须修改内部循环以在每次迭代时创建一个新变量。一种方法是将变量作为参数传递给闭包：for _, v := range values { go func(u string) { fmt.Println(u) done <- true }(v)}在这个例子中，v 的值作为参数传递给匿名函数。然后可以在函数内部访问该值作为变量 u。更简单的方法是创建一个新变量，使用看起来很奇怪但在 Go 中工作正常的声明样式：for _, v := range values { v := v // create a new 'v'. go func() { fmt.Println(v) done <- true }()}因此，在您的情况下，通过添加语句创建一个新变量j := j，for j := 0; j < MAX_TH; j++ { j := j go func() { getWebPageContent("http://www.example.com", messages, j) }()}例如，package mainimport ( "fmt" "io/ioutil" "net/http")func getWebPageContent(url string, c chan int, val int) interface{} { if r, err := http.Get(url); err == nil { defer r.Body.Close() if body, err := ioutil.ReadAll(r.Body); err == nil { c <- val return string(body) } } else { fmt.Println(err) } return "XoX"}const MAX_TH = 40func main() { // pln := fmt.Println messages := make(chan int) for j := 0; j < MAX_TH; j++ { j := j go func() { getWebPageContent("http://www.example.com", messages, j) }() } routine_count := 0 var page_number int for { page_number = <-messages routine_count++ fmt.Println("Page number: ", page_number) if routine_count == MAX_TH { break } } close(messages)}输出：Page number: 23Page number: 6Page number: 1Page number: 3Page number: 28Page number: 32Page number: 18Page number: 22Page number: 0Page number: 36Page number: 7Page number: 21Page number: 12Page number: 2Page number: 5Page number: 4Page number: 33Page number: 13Page number: 20Page number: 27Page number: 29Page number: 8Page number: 31Page number: 10Page number: 17Page number: 25Page number: 19Page number: 35Page number: 14Page number: 38Page number: 15Page number: 30Page number: 37Page number: 39Page number: 26Page number: 9Page number: 16Page number: 11Page number: 24Page number: 34 -
慕码人8056858
我的第一个 golang 回复，可能完全关闭 :-)循环可能如下所示：...for j := 0; j < MAX_TH; j++ { go func(x) { getWebPageContent("http://www.example.com", messages, x) }(j)}...基本上，您定义一个匿名函数并使用参数调用它。你可以用不同的方式来做，但这个解决方案看起来非常实用和时尚:-)
随时随地看视频慕课网APP
相关分类
Go