Golang 如何在 goroutine 之间共享变量?

我正在学习 Go 并试图了解它的并发特性。


我有以下程序。


package main


import (

    "fmt"

    "sync"

)


func main() {

    var wg sync.WaitGroup


    for i := 0; i < 5; i++ {

        wg.Add(1)


        x := i


        go func() {

            defer wg.Done()

            fmt.Println(x)

        }()


    }


    wg.Wait()

    fmt.Println("Done")

}

执行时我得到:


4

0

1

3

2

这正是我想要的。但是,如果我对其稍作修改:


package main


import (

    "fmt"

    "sync"

)


func main() {

    var wg sync.WaitGroup


    for i := 0; i < 5; i++ {

        wg.Add(1)


        go func() {

            defer wg.Done()

            fmt.Println(i)

        }()


    }


    wg.Wait()

    fmt.Println("Done")

}

我得到的是:


5

5

5

5

5

我不太明白其中的区别。谁能帮助解释这里发生了什么以及 Go 运行时如何执行此代码?


汪汪一只猫
浏览 274回答 3
3回答

繁星淼淼

每次运行都有新变量x := i,这段代码通过打印xgoroutine 内部的地址很好地显示了差异:Go Playground:package mainimport (&nbsp; &nbsp; "fmt"&nbsp; &nbsp; "sync")func main() {&nbsp; &nbsp; var wg sync.WaitGroup&nbsp; &nbsp; for i := 0; i < 5; i++ {&nbsp; &nbsp; &nbsp; &nbsp; wg.Add(1)&nbsp; &nbsp; &nbsp; &nbsp; x := i&nbsp; &nbsp; &nbsp; &nbsp; go func() {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; defer wg.Done()&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; fmt.Println(&x)&nbsp; &nbsp; &nbsp; &nbsp; }()&nbsp; &nbsp; }&nbsp; &nbsp; wg.Wait()&nbsp; &nbsp; fmt.Println("Done")}输出:0xc0420301e00xc0420302000xc0420301e80xc0420301f00xc0420301f8Done并构建您的第二个示例go build -race并运行它:您将看到:WARNING: DATA RACE这会很好Go Playground://go build -racepackage mainimport (&nbsp; &nbsp; "fmt"&nbsp; &nbsp; "sync")func main() {&nbsp; &nbsp; var wg sync.WaitGroup&nbsp; &nbsp; for i := 0; i < 5; i++ {&nbsp; &nbsp; &nbsp; &nbsp; wg.Add(1)&nbsp; &nbsp; &nbsp; &nbsp; go func(i int) {&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; defer wg.Done()&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; fmt.Println(i)&nbsp; &nbsp; &nbsp; &nbsp; }(i)&nbsp; &nbsp; }&nbsp; &nbsp; wg.Wait()&nbsp; &nbsp; fmt.Println("Done")}输出:04123Done

慕妹3242003

一般规则是,不要在 goroutine 之间共享数据。在第一个示例中,您基本上为每个 goroutine 提供了自己的 副本x,然后他们按照到达 print 语句的任何顺序将其打印出来。在第二个示例中,它们都引用了相同的循环变量,并且在它们中的任何一个打印它时递增到 5。我不相信那里的输出是有保证的,只是碰巧创建 goroutine 的循环完成得比 goroutine 本身到达打印部分的速度更快。

慕哥6287543

用简单的英语解释有点困难,但我会尽力而为。你看,每次你生成一个新的 goroutine 时,都有一个初始化时间,不管它多么微不足道,它总是在那里。所以,在你的第二种情况下,整个循环在任何 goroutine 开始之前就已经完成了变量的 5 次递增。当 goroutine 完成初始化时,他们看到的只是最终的变量值,即 5。但是,在您的第一种情况下, x 变量保留了 i 变量的副本,以便当 goroutine 启动时, x get 传递给它们。请记住,这里是i递增的,而不是x.&nbsp;x是固定的。因此,当 goroutine 启动时,它们会得到一个固定值。
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Go