为什么goroutine无法读取全局var ops值？

Question

package main

import "fmt"

import "time"

import (

    "runtime"

    "sync/atomic"

)

func init() {

    runtime.GOMAXPROCS(runtime.NumCPU())

}

func main() {

    var t1 = time.Now()

    var ops uint64 = 0

    go func() {

        for {

            time.Sleep(time.Second)

            opsFinal := atomic.LoadUint64(&ops)

            fmt.Println("ops:", opsFinal, "qps:", opsFinal/uint64(time.Since(t1).Seconds()))

        }

    }()

    for {

        atomic.AddUint64(&ops, 1)

        //runtime.Gosched()

    }

}

在这种情况下，每秒输出“ ops：0 qps：0”，为什么不能在goroutine中读取ops？

但是当添加runtime.Gosched（）时，一切正常！

每个人都可以帮助我吗？

Answer 1

我对Go Memory Model的了解是，这是对您编写的程序的正确执行：没有什么可以保证AddUint64()主程序中的调用在goroutine中的调用之前发生LoadUint64()，因此对于每次读取变量的发生都是合法的在发生任何写操作之前。如果编译器知道"sync/atomic"特殊之处并得出增量的结果不可观察的结论，那么我不会感到完全震惊，因此只需删除最终循环即可。无论转到内存模型和同步/原子的文件建议对您所使用的方法。 "sync/atomic"告诫：通过通信共享内存；不要通过共享内存进行通信。一个更好的程序可能看起来像这样：package mainimport "fmt"import "time"func count(op <-chan struct{}) {&nbsp; &nbsp; t1 := time.Now()&nbsp; &nbsp; ops := 0&nbsp; &nbsp; tick := time.Tick(time.Second)&nbsp; &nbsp; for {&nbsp; &nbsp; &nbsp; &nbsp; select {&nbsp; &nbsp; &nbsp; &nbsp; case <-op:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; ops++&nbsp; &nbsp; &nbsp; &nbsp; case <-tick:&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; dt := time.Since(t1).Seconds()&nbsp; &nbsp; &nbsp; &nbsp; &nbsp; &nbsp; fmt.Printf("ops: %d qps: %f\n", ops, float64(ops)/dt)&nbsp; &nbsp; &nbsp; &nbsp; }&nbsp; &nbsp; }}func main() {&nbsp; &nbsp; op := make(chan struct{})&nbsp; &nbsp; go count(op)&nbsp; &nbsp; for {&nbsp; &nbsp; &nbsp; &nbsp; op <- struct{}{}&nbsp; &nbsp; }}请注意，除了通过通道发送的数据外，主程序与goroutine之间没有共享任何状态。

Answer 2

我将更新go版本，请检查，[mh-cbon@pc3 y] $ go run main.go&nbsp;ops: 97465383 qps: 97465383ops: 195722110 qps: 97861055ops: 293058057 qps: 97686019ops: 390971243 qps: 97742810^Csignal: interrupt[mh-cbon@pc3 y] $ go versiongo version go1.10 linux/amd64[mh-cbon@pc3 y] $ gvm use 1.8Now using version go1.8[mh-cbon@pc3 y] $ go versiongo version go1.8 linux/amd64[mh-cbon@pc3 y] $ go run main.go&nbsp;ops: 0 qps: 0ops: 0 qps: 0^Csignal: interrupt[mh-cbon@pc3 y] $&nbsp;