1
0
mirror of https://github.com/golang/go synced 2024-11-11 18:21:40 -07:00

sync: use atomic.Uint32 in Once

This commit is contained in:
mstmdev 2023-10-05 17:27:20 +08:00
parent 36ecff0893
commit 14165018d6
2 changed files with 7 additions and 7 deletions

View File

@ -21,7 +21,7 @@ type Once struct {
// The hot path is inlined at every call site.
// Placing done first allows more compact instructions on some architectures (amd64/386),
// and fewer instructions (to calculate offset) on other architectures.
done uint32
done atomic.Uint32
m Mutex
}
@ -48,7 +48,7 @@ type Once struct {
func (o *Once) Do(f func()) {
// Note: Here is an incorrect implementation of Do:
//
// if atomic.CompareAndSwapUint32(&o.done, 0, 1) {
// if o.done.CompareAndSwap(0, 1) {
// f()
// }
//
@ -58,9 +58,9 @@ func (o *Once) Do(f func()) {
// call f, and the second would return immediately, without
// waiting for the first's call to f to complete.
// This is why the slow path falls back to a mutex, and why
// the atomic.StoreUint32 must be delayed until after f returns.
// the o.done.Store must be delayed until after f returns.
if atomic.LoadUint32(&o.done) == 0 {
if o.done.Load() == 0 {
// Outlined slow-path to allow inlining of the fast-path.
o.doSlow(f)
}
@ -69,8 +69,8 @@ func (o *Once) Do(f func()) {
func (o *Once) doSlow(f func()) {
o.m.Lock()
defer o.m.Unlock()
if o.done == 0 {
defer atomic.StoreUint32(&o.done, 1)
if o.done.Load() == 0 {
defer o.done.Store(1)
f()
}
}

View File

@ -37,7 +37,7 @@ var once *sync.Once
func small7() { // ERROR "can inline small7"
// the Do fast path should be inlined
once.Do(small5) // ERROR "inlining call to sync\.\(\*Once\)\.Do"
once.Do(small5) // ERROR "inlining call to sync\.\(\*Once\)\.Do" "inlining call to atomic\.\(\*Uint32\)\.Load"
}
var rwmutex *sync.RWMutex