package mainimport "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（）時，一切正常！每個人都可以幫助我嗎？
2 回答
蕭十郎
TA貢獻1815條經驗 獲得超13個贊
我對Go Memory Model的了解是，這是對您編寫的程序的正確執行：沒有什么可以保證AddUint64()主程序中的調用在goroutine中的調用之前發生LoadUint64()，因此對于每次讀取變量的發生都是合法的在發生任何寫操作之前。如果編譯器知道"sync/atomic"特殊之處并得出增量的結果不可觀察的結論，那么我不會感到完全震驚，因此只需刪除最終循環即可。
無論轉到內存模型和同步/原子的文件建議對您所使用的方法。 "sync/atomic"告誡：
通過通信共享內存；不要通過共享內存進行通信。
一個更好的程序可能看起來像這樣：
package main
import "fmt"
import "time"
func count(op <-chan struct{}) {
t1 := time.Now()
ops := 0
tick := time.Tick(time.Second)
for {
select {
case <-op:
ops++
case <-tick:
dt := time.Since(t1).Seconds()
fmt.Printf("ops: %d qps: %f\n", ops, float64(ops)/dt)
}
}
}
func main() {
op := make(chan struct{})
go count(op)
for {
op <- struct{}{}
}
}
請注意，除了通過通道發送的數據外，主程序與goroutine之間沒有共享任何狀態。
jeck貓
TA貢獻1909條經驗 獲得超7個贊
我將更新go版本，請檢查，
[mh-cbon@pc3 y] $ go run main.go
ops: 97465383 qps: 97465383
ops: 195722110 qps: 97861055
ops: 293058057 qps: 97686019
ops: 390971243 qps: 97742810
^Csignal: interrupt
[mh-cbon@pc3 y] $ go version
go version go1.10 linux/amd64
[mh-cbon@pc3 y] $ gvm use 1.8
Now using version go1.8
[mh-cbon@pc3 y] $ go version
go version go1.8 linux/amd64
[mh-cbon@pc3 y] $ go run main.go
ops: 0 qps: 0
ops: 0 qps: 0
^Csignal: interrupt
[mh-cbon@pc3 y] $
- 2 回答
- 0 關注
- 281 瀏覽
添加回答
舉報
0/150
提交
取消