atomic
packagestandard libraryThis package is not in the latest version of its module.
Details
Validgo.mod file
The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license
Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version
Modules with tagged versions give importers more predictable builds.
Stable version
When a project reaches major version v1 it is considered stable.
- Learn more about best practices
Repository
Links
Documentation¶
Overview¶
Package atomic provides low-level atomic memory primitivesuseful for implementing synchronization algorithms.
These functions require great care to be used correctly.Except for special, low-level applications, synchronization is betterdone with channels or the facilities of thesync package.Share memory by communicating;don't communicate by sharing memory.
The swap operation, implemented by the SwapT functions, is the atomicequivalent of:
old = *addr*addr = newreturn old
The compare-and-swap operation, implemented by the CompareAndSwapTfunctions, is the atomic equivalent of:
if *addr == old {*addr = newreturn true}return false
The add operation, implemented by the AddT functions, is the atomicequivalent of:
*addr += deltareturn *addr
The load and store operations, implemented by the LoadT and StoreTfunctions, are the atomic equivalents of "return *addr" and"*addr = val".
In the terminology ofthe Go memory model, if the effect ofan atomic operation A is observed by atomic operation B,then A “synchronizes before” B.Additionally, all the atomic operations executed in a programbehave as though executed in some sequentially consistent order.This definition provides the same semantics asC++'s sequentially consistent atomics and Java's volatile variables.
Index¶
- func AddInt32(addr *int32, delta int32) (new int32)
- func AddInt64(addr *int64, delta int64) (new int64)
- func AddUint32(addr *uint32, delta uint32) (new uint32)
- func AddUint64(addr *uint64, delta uint64) (new uint64)
- func AddUintptr(addr *uintptr, delta uintptr) (new uintptr)
- func AndInt32(addr *int32, mask int32) (old int32)
- func AndInt64(addr *int64, mask int64) (old int64)
- func AndUint32(addr *uint32, mask uint32) (old uint32)
- func AndUint64(addr *uint64, mask uint64) (old uint64)
- func AndUintptr(addr *uintptr, mask uintptr) (old uintptr)
- func CompareAndSwapInt32(addr *int32, old, new int32) (swapped bool)
- func CompareAndSwapInt64(addr *int64, old, new int64) (swapped bool)
- func CompareAndSwapPointer(addr *unsafe.Pointer, old, new unsafe.Pointer) (swapped bool)
- func CompareAndSwapUint32(addr *uint32, old, new uint32) (swapped bool)
- func CompareAndSwapUint64(addr *uint64, old, new uint64) (swapped bool)
- func CompareAndSwapUintptr(addr *uintptr, old, new uintptr) (swapped bool)
- func LoadInt32(addr *int32) (val int32)
- func LoadInt64(addr *int64) (val int64)
- func LoadPointer(addr *unsafe.Pointer) (val unsafe.Pointer)
- func LoadUint32(addr *uint32) (val uint32)
- func LoadUint64(addr *uint64) (val uint64)
- func LoadUintptr(addr *uintptr) (val uintptr)
- func OrInt32(addr *int32, mask int32) (old int32)
- func OrInt64(addr *int64, mask int64) (old int64)
- func OrUint32(addr *uint32, mask uint32) (old uint32)
- func OrUint64(addr *uint64, mask uint64) (old uint64)
- func OrUintptr(addr *uintptr, mask uintptr) (old uintptr)
- func StoreInt32(addr *int32, val int32)
- func StoreInt64(addr *int64, val int64)
- func StorePointer(addr *unsafe.Pointer, val unsafe.Pointer)
- func StoreUint32(addr *uint32, val uint32)
- func StoreUint64(addr *uint64, val uint64)
- func StoreUintptr(addr *uintptr, val uintptr)
- func SwapInt32(addr *int32, new int32) (old int32)
- func SwapInt64(addr *int64, new int64) (old int64)
- func SwapPointer(addr *unsafe.Pointer, new unsafe.Pointer) (old unsafe.Pointer)
- func SwapUint32(addr *uint32, new uint32) (old uint32)
- func SwapUint64(addr *uint64, new uint64) (old uint64)
- func SwapUintptr(addr *uintptr, new uintptr) (old uintptr)
- type Bool
- type Int32
- type Int64
- type Pointer
- type Uint32
- func (x *Uint32) Add(delta uint32) (new uint32)
- func (x *Uint32) And(mask uint32) (old uint32)
- func (x *Uint32) CompareAndSwap(old, new uint32) (swapped bool)
- func (x *Uint32) Load() uint32
- func (x *Uint32) Or(mask uint32) (old uint32)
- func (x *Uint32) Store(val uint32)
- func (x *Uint32) Swap(new uint32) (old uint32)
- type Uint64
- func (x *Uint64) Add(delta uint64) (new uint64)
- func (x *Uint64) And(mask uint64) (old uint64)
- func (x *Uint64) CompareAndSwap(old, new uint64) (swapped bool)
- func (x *Uint64) Load() uint64
- func (x *Uint64) Or(mask uint64) (old uint64)
- func (x *Uint64) Store(val uint64)
- func (x *Uint64) Swap(new uint64) (old uint64)
- type Uintptr
- func (x *Uintptr) Add(delta uintptr) (new uintptr)
- func (x *Uintptr) And(mask uintptr) (old uintptr)
- func (x *Uintptr) CompareAndSwap(old, new uintptr) (swapped bool)
- func (x *Uintptr) Load() uintptr
- func (x *Uintptr) Or(mask uintptr) (old uintptr)
- func (x *Uintptr) Store(val uintptr)
- func (x *Uintptr) Swap(new uintptr) (old uintptr)
- type Value
- Bugs
Examples¶
Constants¶
This section is empty.
Variables¶
This section is empty.
Functions¶
funcAddInt32¶
AddInt32 atomically adds delta to *addr and returns the new value.Consider using the more ergonomic and less error-proneInt32.Add instead.
funcAddInt64¶
AddInt64 atomically adds delta to *addr and returns the new value.Consider using the more ergonomic and less error-proneInt64.Add instead(particularly if you target 32-bit platforms; see the bugs section).
funcAddUint32¶
AddUint32 atomically adds delta to *addr and returns the new value.To subtract a signed positive constant value c from x, do AddUint32(&x, ^uint32(c-1)).In particular, to decrement x, do AddUint32(&x, ^uint32(0)).Consider using the more ergonomic and less error-proneUint32.Add instead.
funcAddUint64¶
AddUint64 atomically adds delta to *addr and returns the new value.To subtract a signed positive constant value c from x, do AddUint64(&x, ^uint64(c-1)).In particular, to decrement x, do AddUint64(&x, ^uint64(0)).Consider using the more ergonomic and less error-proneUint64.Add instead(particularly if you target 32-bit platforms; see the bugs section).
funcAddUintptr¶
AddUintptr atomically adds delta to *addr and returns the new value.Consider using the more ergonomic and less error-proneUintptr.Add instead.
funcAndInt32¶added ingo1.23.0
AndInt32 atomically performs a bitwise AND operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneInt32.And instead.
funcAndInt64¶added ingo1.23.0
AndInt64 atomically performs a bitwise AND operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneInt64.And instead.
funcAndUint32¶added ingo1.23.0
AndUint32 atomically performs a bitwise AND operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneUint32.And instead.
funcAndUint64¶added ingo1.23.0
AndUint64 atomically performs a bitwise AND operation on *addr using the bitmask provided as maskand returns the old.Consider using the more ergonomic and less error-proneUint64.And instead.
funcAndUintptr¶added ingo1.23.0
AndUintptr atomically performs a bitwise AND operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneUintptr.And instead.
funcCompareAndSwapInt32¶
CompareAndSwapInt32 executes the compare-and-swap operation for an int32 value.Consider using the more ergonomic and less error-proneInt32.CompareAndSwap instead.
funcCompareAndSwapInt64¶
CompareAndSwapInt64 executes the compare-and-swap operation for an int64 value.Consider using the more ergonomic and less error-proneInt64.CompareAndSwap instead(particularly if you target 32-bit platforms; see the bugs section).
funcCompareAndSwapPointer¶
CompareAndSwapPointer executes the compare-and-swap operation for a unsafe.Pointer value.Consider using the more ergonomic and less error-pronePointer.CompareAndSwap instead.
funcCompareAndSwapUint32¶
CompareAndSwapUint32 executes the compare-and-swap operation for a uint32 value.Consider using the more ergonomic and less error-proneUint32.CompareAndSwap instead.
funcCompareAndSwapUint64¶
CompareAndSwapUint64 executes the compare-and-swap operation for a uint64 value.Consider using the more ergonomic and less error-proneUint64.CompareAndSwap instead(particularly if you target 32-bit platforms; see the bugs section).
funcCompareAndSwapUintptr¶
CompareAndSwapUintptr executes the compare-and-swap operation for a uintptr value.Consider using the more ergonomic and less error-proneUintptr.CompareAndSwap instead.
funcLoadInt32¶
LoadInt32 atomically loads *addr.Consider using the more ergonomic and less error-proneInt32.Load instead.
funcLoadInt64¶
LoadInt64 atomically loads *addr.Consider using the more ergonomic and less error-proneInt64.Load instead(particularly if you target 32-bit platforms; see the bugs section).
funcLoadPointer¶
LoadPointer atomically loads *addr.Consider using the more ergonomic and less error-pronePointer.Load instead.
funcLoadUint32¶
LoadUint32 atomically loads *addr.Consider using the more ergonomic and less error-proneUint32.Load instead.
funcLoadUint64¶
LoadUint64 atomically loads *addr.Consider using the more ergonomic and less error-proneUint64.Load instead(particularly if you target 32-bit platforms; see the bugs section).
funcLoadUintptr¶
LoadUintptr atomically loads *addr.Consider using the more ergonomic and less error-proneUintptr.Load instead.
funcOrInt32¶added ingo1.23.0
OrInt32 atomically performs a bitwise OR operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneInt32.Or instead.
funcOrInt64¶added ingo1.23.0
OrInt64 atomically performs a bitwise OR operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneInt64.Or instead.
funcOrUint32¶added ingo1.23.0
OrUint32 atomically performs a bitwise OR operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneUint32.Or instead.
funcOrUint64¶added ingo1.23.0
OrUint64 atomically performs a bitwise OR operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneUint64.Or instead.
funcOrUintptr¶added ingo1.23.0
OrUintptr atomically performs a bitwise OR operation on *addr using the bitmask provided as maskand returns the old value.Consider using the more ergonomic and less error-proneUintptr.Or instead.
funcStoreInt32¶
StoreInt32 atomically stores val into *addr.Consider using the more ergonomic and less error-proneInt32.Store instead.
funcStoreInt64¶
StoreInt64 atomically stores val into *addr.Consider using the more ergonomic and less error-proneInt64.Store instead(particularly if you target 32-bit platforms; see the bugs section).
funcStorePointer¶
StorePointer atomically stores val into *addr.Consider using the more ergonomic and less error-pronePointer.Store instead.
funcStoreUint32¶
StoreUint32 atomically stores val into *addr.Consider using the more ergonomic and less error-proneUint32.Store instead.
funcStoreUint64¶
StoreUint64 atomically stores val into *addr.Consider using the more ergonomic and less error-proneUint64.Store instead(particularly if you target 32-bit platforms; see the bugs section).
funcStoreUintptr¶
StoreUintptr atomically stores val into *addr.Consider using the more ergonomic and less error-proneUintptr.Store instead.
funcSwapInt32¶added ingo1.2
SwapInt32 atomically stores new into *addr and returns the previous *addr value.Consider using the more ergonomic and less error-proneInt32.Swap instead.
funcSwapInt64¶added ingo1.2
SwapInt64 atomically stores new into *addr and returns the previous *addr value.Consider using the more ergonomic and less error-proneInt64.Swap instead(particularly if you target 32-bit platforms; see the bugs section).
funcSwapPointer¶added ingo1.2
SwapPointer atomically stores new into *addr and returns the previous *addr value.Consider using the more ergonomic and less error-pronePointer.Swap instead.
funcSwapUint32¶added ingo1.2
SwapUint32 atomically stores new into *addr and returns the previous *addr value.Consider using the more ergonomic and less error-proneUint32.Swap instead.
funcSwapUint64¶added ingo1.2
SwapUint64 atomically stores new into *addr and returns the previous *addr value.Consider using the more ergonomic and less error-proneUint64.Swap instead(particularly if you target 32-bit platforms; see the bugs section).
funcSwapUintptr¶added ingo1.2
SwapUintptr atomically stores new into *addr and returns the previous *addr value.Consider using the more ergonomic and less error-proneUintptr.Swap instead.
Types¶
typeBool¶added ingo1.19
type Bool struct {// contains filtered or unexported fields}
A Bool is an atomic boolean value.The zero value is false.
func (*Bool)CompareAndSwap¶added ingo1.19
CompareAndSwap executes the compare-and-swap operation for the boolean value x.
typeInt32¶added ingo1.19
type Int32 struct {// contains filtered or unexported fields}
An Int32 is an atomic int32. The zero value is zero.
func (*Int32)And¶added ingo1.23.0
And atomically performs a bitwise AND operation on x using the bitmaskprovided as mask and returns the old value.
func (*Int32)CompareAndSwap¶added ingo1.19
CompareAndSwap executes the compare-and-swap operation for x.
typeInt64¶added ingo1.19
type Int64 struct {// contains filtered or unexported fields}
An Int64 is an atomic int64. The zero value is zero.
func (*Int64)And¶added ingo1.23.0
And atomically performs a bitwise AND operation on x using the bitmaskprovided as mask and returns the old value.
func (*Int64)CompareAndSwap¶added ingo1.19
CompareAndSwap executes the compare-and-swap operation for x.
typePointer¶added ingo1.19
type Pointer[Tany] struct {// contains filtered or unexported fields}
A Pointer is an atomic pointer of type *T. The zero value is a nil *T.
func (*Pointer[T])CompareAndSwap¶added ingo1.19
CompareAndSwap executes the compare-and-swap operation for x.
func (*Pointer[T])Load¶added ingo1.19
func (x *Pointer[T]) Load() *T
Load atomically loads and returns the value stored in x.
typeUint32¶added ingo1.19
type Uint32 struct {// contains filtered or unexported fields}
A Uint32 is an atomic uint32. The zero value is zero.
func (*Uint32)And¶added ingo1.23.0
And atomically performs a bitwise AND operation on x using the bitmaskprovided as mask and returns the old value.
func (*Uint32)CompareAndSwap¶added ingo1.19
CompareAndSwap executes the compare-and-swap operation for x.
func (*Uint32)Or¶added ingo1.23.0
Or atomically performs a bitwise OR operation on x using the bitmaskprovided as mask and returns the old value.
typeUint64¶added ingo1.19
type Uint64 struct {// contains filtered or unexported fields}
A Uint64 is an atomic uint64. The zero value is zero.
func (*Uint64)And¶added ingo1.23.0
And atomically performs a bitwise AND operation on x using the bitmaskprovided as mask and returns the old value.
func (*Uint64)CompareAndSwap¶added ingo1.19
CompareAndSwap executes the compare-and-swap operation for x.
func (*Uint64)Or¶added ingo1.23.0
Or atomically performs a bitwise OR operation on x using the bitmaskprovided as mask and returns the old value.
typeUintptr¶added ingo1.19
type Uintptr struct {// contains filtered or unexported fields}
A Uintptr is an atomic uintptr. The zero value is zero.
func (*Uintptr)And¶added ingo1.23.0
And atomically performs a bitwise AND operation on x using the bitmaskprovided as mask and returns the old value.
func (*Uintptr)CompareAndSwap¶added ingo1.19
CompareAndSwap executes the compare-and-swap operation for x.
func (*Uintptr)Or¶added ingo1.23.0
Or atomically performs a bitwise OR operation on x using the bitmaskprovided as mask and returns the updated value after the OR operation.
typeValue¶added ingo1.4
type Value struct {// contains filtered or unexported fields}
A Value provides an atomic load and store of a consistently typed value.The zero value for a Value returns nil fromValue.Load.OnceValue.Store has been called, a Value must not be copied.
A Value must not be copied after first use.
Example (Config)¶
The following example shows how to use Value for periodic program config updatesand propagation of the changes to worker goroutines.
package mainimport ("sync/atomic""time")func loadConfig() map[string]string {return make(map[string]string)}func requests() chan int {return make(chan int)}func main() {var config atomic.Value // holds current server configuration// Create initial config value and store into config.config.Store(loadConfig())go func() {// Reload config every 10 seconds// and update config value with the new version.for {time.Sleep(10 * time.Second)config.Store(loadConfig())}}()// Create worker goroutines that handle incoming requests// using the latest config value.for i := 0; i < 10; i++ {go func() {for r := range requests() {c := config.Load()// Handle request r using config c._, _ = r, c}}()}}
Example (ReadMostly)¶
The following example shows how to maintain a scalable frequently read,but infrequently updated data structure using copy-on-write idiom.
package mainimport ("sync""sync/atomic")func main() {type Map map[string]stringvar m atomic.Valuem.Store(make(Map))var mu sync.Mutex // used only by writers// read function can be used to read the data without further synchronizationread := func(key string) (val string) {m1 := m.Load().(Map)return m1[key]}// insert function can be used to update the data without further synchronizationinsert := func(key, val string) {mu.Lock() // synchronize with other potential writersdefer mu.Unlock()m1 := m.Load().(Map) // load current value of the data structurem2 := make(Map) // create a new valuefor k, v := range m1 {m2[k] = v // copy all data from the current object to the new one}m2[key] = val // do the update that we needm.Store(m2) // atomically replace the current object with the new one// At this point all new readers start working with the new version.// The old version will be garbage collected once the existing readers// (if any) are done with it.}_, _ = read, insert}
func (*Value)CompareAndSwap¶added ingo1.17
CompareAndSwap executes the compare-and-swap operation for theValue.
All calls to CompareAndSwap for a given Value must use values of the sameconcrete type. CompareAndSwap of an inconsistent type panics, as doesCompareAndSwap(old, nil).
func (*Value)Load¶added ingo1.4
Load returns the value set by the most recent Store.It returns nil if there has been no call to Store for this Value.
Notes¶
Bugs¶
On 386, the 64-bit functions use instructions unavailable before the Pentium MMX.
On non-Linux ARM, the 64-bit functions use instructions unavailable before the ARMv6k core.
On ARM, 386, and 32-bit MIPS, it is the caller's responsibility to arrangefor 64-bit alignment of 64-bit words accessed atomically via the primitiveatomic functions (typesInt64 andUint64 are automatically aligned).The first word in an allocated struct, array, or slice; in a globalvariable; or in a local variable (because on 32-bit architectures, thesubject of 64-bit atomic operations will escape to the heap) can berelied upon to be 64-bit aligned.