golang sync/atomic 包？

Question

我写了一段代码记录请求数

package main

import (
    "log"
    "net/http"
    "runtime"
    "sync/atomic"
)

var count int32 = 0

func test(w http.ResponseWriter, r *http.Request) {
    count = atomic.LoadInt32(&count)
    atomic.AddInt32(&count, 1)
    log.Println("count:", count)
}
func main() {
    runtime.GOMAXPROCS(runtime.NumCPU() - 1)
    http.HandleFunc("/", test)
    http.ListenAndServe(":8080", nil)
}

考虑到并发的条件，所以使用原子包。我通过 apache ab 工具测试代码

ab -c 400 -n 1000 http://localhost:8080/

结果正确： result 但是，有人说他在他的电脑上得到了1004或其他号码，我已经测试了很多次代码，但是在我的电脑上结果是正确的，我的方法有问题吗？我是新手，先谢谢了。

Answer 1

您使用的 sync/atomic 包不正确。如果你有一个原子变量，ALL读写必须使用原子函数来完成。

您的代码已修复，因此 count 变量不会以非原子方式写入或读取：

package main

import (
    "log"
    "net/http"
    "runtime"
    "sync/atomic"
)

var count int32

func test(w http.ResponseWriter, r *http.Request) {
    currentCount := atomic.LoadInt32(&count)
    atomic.AddInt32(&count, 1)
    log.Println("count:", currentCount)
}
func main() {
    runtime.GOMAXPROCS(runtime.NumCPU() - 1)
    http.HandleFunc("/", test)
    http.ListenAndServe(":8080", nil)
}

golang sync/atomic 包？

golang sync/atomic package?

atomic

go