创建 goroutines 是异步的吗?
Are creating go routines asynchrnous?
我正在尝试使用大量 goroutine 获取 API 的内容。
我正在使用 for 循环遍历不同的字符,但在发送请求之前,forloop 似乎达到了它的最终值。
package main
import (
"encoding/json"
"fmt"
"net/http"
"sync"
)
type people struct {
Name string `json:"name"`
}
func main(){
names := make(chan string, 25)
var wg sync.WaitGroup
for i := 0; i < 25; i++ {
wg.Add(1)
go func() {
defer wg.Done()
var p people
url := fmt.Sprintf("https://swapi.dev/api/people/%d", i)
getJSON(url, &p)
names <- p.Name
}()
}
name := <-names
fmt.Println(name)
wg.Wait()
}
func getJSON(url string, target interface{}) error {
r, err := http.Get(url)
if err != nil {
return err
}
defer r.Body.Close()
json.NewDecoder(r.Body).Decode(target)
return nil
}
另外,如果有人能提高我的代码质量,我将不胜感激,我对Golang很陌生,没有任何人可以学习!
你们go例程都在使用同一个变量i
。因此,在第一个循环中,您启动一个 goroutine,它从 i
生成 url,在下一个循环中,i
在该例程有机会 运行 之前递增。
这是 GoLang 中的一个常见错误。解决方案是为每个循环创建一个变量,并将该变量向前传递。您可以使用这样的闭包 (playground).
for i := 0; i < 25; i++ {
wg.Add(1)
localI := i
go func() {
defer wg.Done()
var p people
// Use LocalI here
url := fmt.Sprintf("https://swapi.dev/api/people/%d", localI)
getJSON(url, &p)
names <- p.Name
}()
}
或者作为函数(游乐场)的参数
for i := 0; i < 25; i++ {
wg.Add(1)
localI := i
go func(localI int) {
defer wg.Done()
var p people
// Use LocalI here
url := fmt.Sprintf("https://swapi.dev/api/people/%d", localI)
getJSON(url, &p)
names <- p.Name
// Pass i here. Since I is a primitive, it is passed by value, not reference.
// Meaning a copy is made.
}(i)
}
这里有一篇关于你所犯错误的很好的记录:
https://github.com/golang/go/wiki/CommonMistakes#using-goroutines-on-loop-iterator-variables
上面那篇也很好看!
我正在尝试使用大量 goroutine 获取 API 的内容。 我正在使用 for 循环遍历不同的字符,但在发送请求之前,forloop 似乎达到了它的最终值。
package main
import (
"encoding/json"
"fmt"
"net/http"
"sync"
)
type people struct {
Name string `json:"name"`
}
func main(){
names := make(chan string, 25)
var wg sync.WaitGroup
for i := 0; i < 25; i++ {
wg.Add(1)
go func() {
defer wg.Done()
var p people
url := fmt.Sprintf("https://swapi.dev/api/people/%d", i)
getJSON(url, &p)
names <- p.Name
}()
}
name := <-names
fmt.Println(name)
wg.Wait()
}
func getJSON(url string, target interface{}) error {
r, err := http.Get(url)
if err != nil {
return err
}
defer r.Body.Close()
json.NewDecoder(r.Body).Decode(target)
return nil
}
另外,如果有人能提高我的代码质量,我将不胜感激,我对Golang很陌生,没有任何人可以学习!
你们go例程都在使用同一个变量i
。因此,在第一个循环中,您启动一个 goroutine,它从 i
生成 url,在下一个循环中,i
在该例程有机会 运行 之前递增。
这是 GoLang 中的一个常见错误。解决方案是为每个循环创建一个变量,并将该变量向前传递。您可以使用这样的闭包 (playground).
for i := 0; i < 25; i++ {
wg.Add(1)
localI := i
go func() {
defer wg.Done()
var p people
// Use LocalI here
url := fmt.Sprintf("https://swapi.dev/api/people/%d", localI)
getJSON(url, &p)
names <- p.Name
}()
}
或者作为函数(游乐场)的参数
for i := 0; i < 25; i++ {
wg.Add(1)
localI := i
go func(localI int) {
defer wg.Done()
var p people
// Use LocalI here
url := fmt.Sprintf("https://swapi.dev/api/people/%d", localI)
getJSON(url, &p)
names <- p.Name
// Pass i here. Since I is a primitive, it is passed by value, not reference.
// Meaning a copy is made.
}(i)
}
这里有一篇关于你所犯错误的很好的记录: https://github.com/golang/go/wiki/CommonMistakes#using-goroutines-on-loop-iterator-variables
上面那篇也很好看!