sync/atomic StoreInt32 奇怪的行为
sync/atomic StoreInt32 strange behavior
此代码已简化并描述了我的问题。 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() {
// ...
}
此代码已简化并描述了我的问题。 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() {
// ...
}