在并发goroutine期间如何锁定/同步Go中对变量的访问？

Question

在他对以下问题的回答中： Golang for Windows行为不稳定？ 建议用户@distributed锁定/同步并发goroutine上对共享变量的访问。

我怎样才能做到这一点？

有关此问题的更多信息：

我获得views了同时在多个goroutines上运行的代码（带有闭包的返回函数）：

func makeHomeHandler() func(c *http.Conn, r *http.Request) {

    views := 1

    return func(c *http.Conn, r *http.Request) {

        fmt.Fprintf(c, "Counting %s, %d so far.", r.URL.Path[1:], views)

        views++

    }

}

看起来IO功能很费时间，结果我得到了这种输出：

Counting monkeys, 5 so far.

Counting monkeys, 5 so far.

Counting monkeys, 5 so far.

Counting monkeys, 8 so far.

Counting monkeys, 8 so far.

Counting monkeys, 8 so far.

Counting monkeys, 11 so far.

它可以很好地递增，但是当它被打印时，我可以看到print + incrementing操作不是原子的。

如果我将其更改为：

func makeHomeHandler() func(c *http.Conn, r *http.Request) {

    views := 0

    return func(c *http.Conn, r *http.Request) {

        views++

        // I can only hope that other goroutine does not increment the counter 

        // at this point, i.e., right after the previous line and before the 

        // next one are executed!

        views_now := views

        fmt.Fprintf(c, "Counting %s, %d so far.", r.URL.Path[1:], views_now)

    }

}

似乎工作正常，但我不确定是否最终不会失败...

Answer 1

的同步包有一些同步原语。根据问题，您可以使用RWMutex或普通的Mutex。如果您想要更具体的答案，请提供更多信息。编辑：阅读链接的问题后，您可能正在寻找sync / atomic，尽管Mutex也很好。Edit2：我看到您用示例更新了您的帖子。这是使用同步/原子的代码。func makeHomeHandler() func(w http.ResponseWriter, r *http.Request) {    var views *uint64 = new(uint64)    atomic.StoreUint64(views, 0) // I don't think this is strictly necessary    return func(w http.ResponseWriter, r *http.Request) {        // Atomically add one to views and get the new value        // Perhaps you want to subtract one here        views_now := atomic.AddUint64(views, 1)         fmt.Fprintf(w, "Counting %s, %d so far.", r.URL.Path[1:], views_now)    }}