与 for 循环和匿名函数的并发行为异常

Question

我已经找到了一种让代码按照我想要的方式运行的方法，但我想了解它为什么会这样，以便我对 Go 并发性的理解有所提高。我正在测试sync.WaitGroup等待一些 goroutine 完成，因为我计划以这种方式多次上传到 Amazon S3。这是我最初的代码：func main() {    var wg sync.WaitGroup    for i := 1; i <= 5; i++ {        wg.Add(1)        go func() {            fmt.Println(i)            time.Sleep(time.Second * 1)            wg.Done()        }()    }    wg.Wait()}我很惊讶地看到输出是：6, 6, 6, 6, 6。而不是像：2, 4, 1, 5, 3。由于循环甚至没有达到 6，这对我来说毫无意义。后来我将该i变量作为参数传递给匿名函数，然后它的行为符合我的预期。为什么会发生这种情况？我不明白。

Answer 1

在这种情况下，在 for 循环完成之前，不会调度任何 goroutine。为了使 for 循环中断，i必须不小于或等于 5，因此在该点为 6。当 goroutine 运行时，它们每个都会打印i在闭包中捕获的单个变量的值。

当您将i参数作为参数传递给函数时，您将当前值复制到一个新变量中，并捕获当时的值。

Answer 2

要回答您的问题，您必须传入i您的，func以便每个例程都有自己的i.

所以你的代码应该是这样的

func main() {

    var wg sync.WaitGroup

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

        wg.Add(1)

        go func(i int) {

            fmt.Println(i)

            time.Sleep(time.Second * 1)

            wg.Done()

        }(i)

    }

    wg.Wait()

}

我编写了这个实用程序函数来帮助并行化一组函数：

import "sync"

// Parallelize parallelizes the function calls

func Parallelize(functions ...func()) {

    var waitGroup sync.WaitGroup

    waitGroup.Add(len(functions))

    defer waitGroup.Wait()

    for _, function := range functions {

        go func(copy func()) {

            defer waitGroup.Done()

            copy()

        }(function)

    }

}

所以在你的情况下，我们可以这样做

func main() {

    functions := []func(){}

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

            function := func(i int) func() {

                return func() {

                        fmt.Println(i)

                }

            }(i)

        functions = append(functions, function)

    }

    Parallelize(functions...)

    fmt.Println("Done")

}

如果你想使用 Parallelize 功能，你可以在这里找到它https://github.com/shomali11/util