时间戳

首页 > 解决方案 > 数据竞争，两个 goroutine 加上相同的 val

go - 数据竞争，两个 goroutine 加上相同的 val

问题描述

考虑下面的代码，在我看来，val 将在 100 到 200 之间，但它总是 200

var val = 0

func main() {
    num := runtime.NumCPU()
    fmt.Println("使用cpu数量", num)
    go add("A")
    go add("B")
    time.Sleep(1 * time.Second)
    fmt.Println("val的最终结果", val)
}

func add(proc string) {
    for i := 0; i < 100; i++ {
        val++
        fmt.Printf("execute process[%s] and val is %d\n", proc, val)
        time.Sleep(5 * time.Millisecond)
    }
}

为什么 val 最后总是 200？

标签： godata-race

解决方案

您的代码有两个问题：

  1. 你有一个数据竞争——val在没有同步的情况下同时写入和读取。它的存在使得对程序结果的推理变得毫无意义。
  2. 1 秒的睡眠main()时间太短 - 1 秒后 goroutines 可能还没有完成。您根本不希望fmt.Printf花费任何时间，但控制台输出确实需要大量时间（在某些操作系统上比其他操作系统长）。所以循环不会花费 100 * 5 = 500 毫秒，而是要长得多。

这是一个固定版本，它以原子方式递增val并正确等待两个 goroutine 完成，而不是假设它们将在 1 秒内完成。

var val = int32(0)

func main() {
    num := runtime.NumCPU()
    fmt.Println("使用cpu数量", num)
    var wg sync.WaitGroup
    wg.Add(2)
    go add("A", &wg)
    go add("B", &wg)
    wg.Wait()
    fmt.Println("val的最终结果&quot;, atomic.LoadInt32(&val))
}

func add(proc string, wg *sync.WaitGroup) {
    for i := 0; i < 100; i++ {
        tmp := atomic.AddInt32(&val, 1)
        fmt.Printf("execute process[%s] and val is %d\n", proc, tmp)
        time.Sleep(5 * time.Millisecond)
    }
    wg.Done()
}

推荐阅读