使用 Go 原子模拟等待组

小伙伴们有没有觉得学习Golang很有意思？有意思就对了！今天就给大家带来《使用 Go 原子模拟等待组》，以下内容将会涉及到，若是在学习中对其中部分知识点有疑问，或许看了本文就能帮到你！

我有以下代码来生成许多 goroutine。每个 goroutine 都会执行不同数量的工作（此处通过不同的循环长度进行模拟），然后自动在其作业结构中设置一个变量以表示其已完成。 main() goroutine 使用compare_and_swap 检查所有作业结构是否完成。这段代码很活泼，变量 finish 超出了 numjobs，我不明白为什么。

我知道我可以使用等待组来实现此目的，但是，我想了解为什么会失败。

type job struct {
    id    int
    done  uint32
    loops int
}

const (
    numjobs int = 10000
)

func (j *job) work() {
    for k := 0; k < j.loops; k++ {

    }
    fmt.Printf("Ending job %d\n", j.id)
    atomic.StoreUint32(&j.done, 1)

}
func main() {
    // Memory for jobs
    jobs := make([]job, numjobs)

    // Kick off the jobs, each running a random number of loops
    for i := 0; i < numjobs; i++ {
        jobs[i].id = i
        jobs[i].loops = rand.Intn(1000000)
        go (&jobs[i]).work()
    }

    // Track when all jobs are done
    finish := 0
    for finish != numjobs {
        for _, job := range jobs {
            if atomic.CompareAndSwapUint32(&job.done, 1, 0) {
                finish++
            }
        }
        fmt.Printf("Finished %d jobs\n", finish)
    }

}

正确答案

您正在更新 job 的副本。试试这个：

for job := range jobs {
            if atomic.CompareAndSwapUint32(&jobs[job].done, 1, 0) {
                finish++
            }
        }

终于介绍完啦！小伙伴们，这篇关于《使用 Go 原子模拟等待组》的介绍应该让你收获多多了吧！欢迎大家收藏或分享给更多需要学习的朋友吧~golang学习网公众号也会发布Golang相关知识，快来关注吧！