登录
首页 >  Golang >  Go问答

Go 例程的执行是并发的吗?

来源:stackoverflow

时间:2024-03-25 08:09:35 420浏览 收藏

**摘要:** 本文探讨了在 Go 语言中使用大量 goroutine 并发执行时遇到的问题。作者尝试通过 for 循环获取 API 内容,但发现循环未达到预期值。文章指出,这是由于所有 goroutine 使用相同的循环变量导致的,导致变量在第一个 goroutine 运行之前就递增了。文章提供了两种解决方案:使用闭包创建每个循环的局部变量,或将循环变量作为函数参数传递。

问题内容

我正在尝试使用大量 goroutine 获取 api 的内容。 我正在使用 for 循环来迭代不同的字符,但在发送请求之前,for 循环似乎达到了其最终值。

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 很陌生,没有人可以学习!


解决方案


您的例程都使用相同的变量 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

上面的那一篇也很好读!

今天关于《Go 例程的执行是并发的吗?》的内容介绍就到此结束,如果有什么疑问或者建议,可以在golang学习网公众号下多多回复交流;文中若有不正之处,也希望回复留言以告知!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>