go - 同步/原子 StoreInt32 奇怪的行为

标签 go atomic

此代码已简化并描述了我的问题。 atomic.StoreInt32 似乎不起作用,但我不确定为什么。

package main
import (
    "fmt"
    "sync/atomic"
)

type slave struct {
    failed int32
}
func NewSlave() slave {
    return slave{0}
}
func (worker slave) Fail() {
    atomic.StoreInt32(&worker.failed, 1) // Here's the problem.
}
func (worker slave) IsFailed() bool {
    failed := atomic.LoadInt32(&worker.failed) == 1
    return failed
}
func (worker slave) FailureReset() {
    atomic.StoreInt32(&worker.failed, 0)
}

func main() {
    s := NewSlave()
    fmt.Println(s.IsFailed())
    s.Fail()
    fmt.Println(s.IsFailed())
    s.FailureReset()
    fmt.Println(s.IsFailed())
}

->输出:

false 0
false 0
false 0

->测试于:

recolic@RECOLICPC ~/tmp> go version
go version go1.9.2 linux/amd64
recolic@RECOLICPC ~/tmp> uname -a
Linux RECOLICPC 4.13.12-1-ARCH #1 SMP PREEMPT Wed Nov 8 11:54:06 CET 2017 x86_64 GNU/Linux

我读过:usage golang atomic LoadInt32/StoreInt32 (64)

最佳答案

您需要让您的方法采用指针接收器。正如所写的那样,这些函数在您的工作人员的副本上运行,因此用于调用该方法的工作人员不会更改。像这样定义方法:

func (worker *slave) Fail() {
    // ...
}

关于go - 同步/原子 StoreInt32 奇怪的行为,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/47342816/

相关文章:

go - 在 Go 中使用新类型包装器作为 ID 是惯用的吗?

c++ - 如何在 C++ 中自动添加和获取 128 位数字?

java - 不可变映射的无锁原子更新

c++ - 无锁双向链表的原子操作

Image.At 返回零

go - 来自多个测试用例的类似 sqlmock 期望导致 false 失败

http - 发送请求时如何使用uTLS连接?

Golang 基准测试 b.StopTimer() 挂起——是我吗?

c++ - 如何确保成员是 4 字节对齐的?

node.js - MongoDB:对 2 个集合的原子调用(查找+插入)