开篇
并发是业务开发中常常要面对的问题，许多时分咱们会直接用一把 sync.Mutex 互斥锁来线性化处理，确保每一时间进入临界区的 goroutine 只要一个。这样避免了并发，但功用也随着降低操作系统是一种什么软件。
所以，咱们进而又有操作系统是一种了 RWMutex 读写锁，确保了多个读恳求的并发处操作系统的五大功能理，对共享资源的写操作和读操作则差异看待，并消除指针式万用表了读操作之间的互斥。
回想下咱们此前对 Mutex 和 RWMutex 原理的解析，锁的完成自身仍是指针c语言基于 atomic 包供给的原子操作，辅之以自旋等处理。许多时分其实咱操作系统是什么的接口们不太需求【锁住资源】这个语意，而是一个线程的几种状态【原子操作】就 ok。这篇文章咱们来看一下 atomic 包供给的才能。
原子操作
所谓原子操作，关键在于是否架构师和程序员的区别能被中止。Golang 的调度器一同或许需求处理成操作系统是计算机系统中的百上千个 goroutine 的运转，即使 CPU 是多指针数学核的，一同运转的协程数量，也大体指针万用表读数图解上和 GMP 调度模型中的 M（体系线程）保持一致。
所以，仍是那句老话，并发是一种假象，并不是大家在每个时间都一同履行，而是分时操控。比方单核的场景，CPU 在履行一个gorout操作系统对磁盘进行读写的单位i线程和进程的区别是什么ne 一段时间后，切换到另一个goroutine，过段线程数越多越好吗时间再切换回来。
程序代码最终会被翻译为 CPU 指令，这一点很关键。一个稀松平常的 a := 1 赋值句子，底层也会被拆为多条 CPU 指令。留意，一旦是架构师证书多条 CPU 指令，意味着什么呢？
它意味着，或许履行一半就会被调度器切走，pause 在这个地方。当前 goroutine 就进入非运转态，调度其他的 goro操作系统是计算机系统中的utine 去了。假如此刻写的变线程的几种状态量能够被其他 goroutine 读到，就会架构工程师读到不完整的数据。
此刻数据或许处于任何状况，这也是为什么，Golang 的内存模型主张大家，好好用锁，用 at架构师工资omic，”Don’t be clever”，由于并发的bug一般都是很难复现的，一操作系统的主要功能是旦出现对出产环境或许发生很严重的事端。
原子操作架构师和程序员的区别实质上是由 CPU 供给的芯片级别的支撑，原子操作在进行的过程中是不允许中止的。即使在具有多 CPU 核心，或许多 CPU 的计算机体系中，原子操作的确保也是能够信任的。这也是为什么 Mutex 和 RWMutex 都基于原子操作来完成。
操作体系层面只对针对二进制位或整数的原子操指针万用表读数图解作供给了支撑。一般其实不同位的计算机，或许操作体系，供给的原子才能是有差异的。但 Golang 运转时协助咱们屏蔽了这些困扰，只需求操作系统的主要功能是使指针说漫用 atomic 包中的函数即可完成原子操作。
关于单处理器单指针式万用表核体系来说，架构师证书假如一个操作是由一个 CPU 指令来完成的，那么它便是原子操作，比方它的 XCHG 和 INC 等指令。假如操作是基于多条指令来完成的，那么，履行的过程中或架构师工资许会被中止，并履行上下文切换，这样的话，原子性的确保就被打破了，由于这个时分，操作或许只履行了一半。
在多处理器多核体系中，原子操作的完成就比较复杂了。由于 cache 的存在，单个核上的单个指令进行原子操作的时分，你要确保其它处理器或许核不访问此原子操作的地址，或许是确保其它处理器或许核总是访问原子操作之后的最新的值。x86 架构中供给了指令前缀 L线程池的七个参数OC操作系统是一种K，LOCK 确保了指令（比方 LOCK CMPXCHG op1、op2）不会受其它处理器或 CPU 核的影响，有些指令（比方 XCHG）操作系统的主要功能是自身就供给 Lock 的机制。不同的 CPU 架构供线程和进程的区别是什么给的原子操作指令的方法也是不同的，比方关于多核的 MIPS 和 A架构图模板RM，供指针是什么给了 LL/SC（Load Link/Store Conditional架构图模板）指令，能够协助完成原子操作（ARMLL/SC 指令 LDREX 和 STREX）。
事实上假如你看 atomic 包的官方代码注释也会发现，现在在一线程撕裂者些架构上指针是什么 atomic 是存在bug的，需求留操作系统意：
// BUG(rsc): 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 arrange for 64-bit alignment of 64-bit words accessed atomically.
// The first word in a variable or in an allocated struct, array, or slice can
// be relied upon to be 64-bit aligned.
atomic 包
sync/atomic包中的函数能够做架构的原子操作有：加法（add）、比较并交流（compare架构师工资 and swap，简称 CAS）、加载（load）、存储（store）和交流（swap）。
这些函数针对的数据类型并不多。可是，对这些类型中的每一个，sync/atomic包都会有一套函数给予支撑。这些数据类型有：int32、int64、uint32、uint64、uintptr，以及unsafe包中的Pointer。不过，针对unsafe.Pointer类型，该包并未供给进行原子加法操作的函数。
此外，sync/atomic包还供给了一个名为Value的类型，它能够被用来存储恣意类型的值。
才能其实直接参阅源码即可，这儿的完成在 runtime，直接看 src 下线程池的七个参数的 atomic 包只作为文档使用：
抓住一点即可：
第一个参数 addr 便是你要修正的指针。
（传值是没有意义的，由于 Golang 是传值而不是引用，意味着你假如传了个 int32架构图怎么制作 类型的变量作为入参到一个函数，实质是 copy，你是无法修正本来的值的）
un线程是什么意思safe.Pointer类型虽然是指针类型，可是那些原子操作函数要操作的是这个指针值，而不是它指向的操作系统是一种那个值，所以需求的仍然是指向这个指针值的指针。
只需原子操作函数拿到了被操作值的指针，就能够定位到存储该值的内存地操作系统对磁盘进行读写的单位址。只要这样，它们操作系统的五大功能才能够经过底层的指令，准确地操作这个内存地址上的数据。
package atomic
import (
"unsafe"
)
// BUG(rsc): 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 arrange for 64-bit alignment of 64-bit words accessed atomically.
// The first word in a variable or in an allocated struct, array, or slice can
// be relied upon to be 64-bit aligned.
// SwapInt32 atomically stores new into *addr and returns the previous *addr value.
func SwapInt32(addr *int32, new int32) (old int32)
// SwapInt64 atomically stores new into *addr and returns the previous *addr value.
func SwapInt64(addr *int64, new int64) (old int64)
// SwapUint32 atomically stores new into *addr and returns the previous *addr value.
func SwapUint32(addr *uint32, new uint32) (old uint32)
// SwapUint64 atomically stores new into *addr and returns the previous *addr value.
func SwapUint64(addr *uint64, new uint64) (old uint64)
// SwapUintptr atomically stores new into *addr and returns the previous *addr value.
func SwapUintptr(addr *uintptr, new uintptr) (old uintptr)
// SwapPointer atomically stores new into *addr and returns the previous *addr value.
func SwapPointer(addr *unsafe.Pointer, new unsafe.Pointer) (old unsafe.Pointer)
// CompareAndSwapInt32 executes the compare-and-swap operation for an int32 value.
func CompareAndSwapInt32(addr *int32, old, new int32) (swapped bool)
// CompareAndSwapInt64 executes the compare-and-swap operation for an int64 value.
func CompareAndSwapInt64(addr *int64, old, new int64) (swapped bool)
// CompareAndSwapUint32 executes the compare-and-swap operation for a uint32 value.
func CompareAndSwapUint32(addr *uint32, old, new uint32) (swapped bool)
// CompareAndSwapUint64 executes the compare-and-swap operation for a uint64 value.
func CompareAndSwapUint64(addr *uint64, old, new uint64) (swapped bool)
// CompareAndSwapUintptr executes the compare-and-swap operation for a uintptr value.
func CompareAndSwapUintptr(addr *uintptr, old, new uintptr) (swapped bool)
// CompareAndSwapPointer executes the compare-and-swap operation for a unsafe.Pointer value.
func CompareAndSwapPointer(addr *unsafe.Pointer, old, new unsafe.Pointer) (swapped bool)
// AddInt32 atomically adds delta to *addr and returns the new value.
func AddInt32(addr *int32, delta int32) (new int32)
// 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)).
func AddUint32(addr *uint32, delta uint32) (new uint32)
// AddInt64 atomically adds delta to *addr and returns the new value.
func AddInt64(addr *int64, delta int64) (new int64)
// 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)).
func AddUint64(addr *uint64, delta uint64) (new uint64)
// AddUintptr atomically adds delta to *addr and returns the new value.
func AddUintptr(addr *uintptr, delta uintptr) (new uintptr)
// LoadInt32 atomically loads *addr.
func LoadInt32(addr *int32) (val int32)
// LoadInt64 atomically loads *addr.
func LoadInt64(addr *int64) (val int64)
// LoadUint32 atomically loads *addr.
func LoadUint32(addr *uint32) (val uint32)
// LoadUint64 atomically loads *addr.
func LoadUint64(addr *uint64) (val uint64)
// LoadUintptr atomically loads *addr.
func LoadUintptr(addr *uintptr) (val uintptr)
// LoadPointer atomically loads *addr.
func LoadPointer(addr *unsafe.Pointer) (val unsafe.Pointer)
// StoreInt32 atomically stores val into *addr.
func StoreInt32(addr *int32, val int32)
// StoreInt64 atomically stores val into *addr.
func StoreInt64(addr *int64, val int64)
// StoreUint32 atomically stores val into *addr.
func StoreUint32(addr *uint32, val uint32)
// StoreUint64 atomically stores val into *addr.
func StoreUint64(addr *uint64, val uint64)
// StoreUintptr atomically stores val into *addr.
func StoreUintptr(addr *uintptr, val uintptr)
// StorePointer atomically stores val into *addr.
func StorePointer(addr *unsafe.Pointer, val unsafe.Pointer)
最简易的自旋锁
CAS 是经典的模式了，Compare And Swap，只要在操作系统的五大功能【当前的值等于 old 时，赋值为 new】，假如你看线程撕裂者过 Mutex 和 RWMutex 源码的话就会发现，其实锁的完成也是高度依赖 atomic 的 CAS 函数的。
这儿咱们能够用 CAS操作系统 做一个简易的自旋锁（达观锁）。完成的效果：
- 只要第一个来获取锁的能成功（即 Swap），其他的由操作系统的基本特征于 old 对不上，所以 CAS 的返回值 swapped 为 false；
- 无法获取锁的 goroutine 进入自旋（也便是先休眠，过一段时间持续探测能否获取锁）。
for {
if atomic.CompareAndSwapInt32(&num2, 10, 0) {
fmt.Println("The second number has gone to zero.")
break
}
time.Sleep(time.Millisecond * 500)
}
atomic.Value
Golang 在 1.4 的时分就添加了关于 atomic.Value 的支撑，看过源码你会发现它线程和进程的区别是什么便是一个空的 interface{}，所以 Value 的实质是个容器，能够被用来“原子地”存储和加载恣意的值，并且是开箱即用的。
// A Value provides an atomic load and store of a consistently typed value.
// The zero value for a Value returns nil from Load.
// Once Store has been called, a Value must not be copied.
//
// A Value must not be copied after first use.
type Value struct {
v any
}
// ifaceWords is interface{} internal representation.
type ifaceWords struct {
typ unsafe.Pointer
data unsafe.Pointer
}
// Load returns the value set by the most recent Store.
// It returns nil if there has been no call to Store for this Value.
func (v *Value) Load() (val any) {
vp := (*ifaceWords)(unsafe.Pointer(v))
typ := LoadPointer(&vp.typ)
if typ == nil || typ == unsafe.Pointer(&firstStoreInProgress) {
// First store not yet completed.
return nil
}
data := LoadPointer(&vp.data)
vlp := (*ifaceWords)(unsafe.Pointer(&val))
vlp.typ = typ
vlp.data = data
return
}
var firstStoreInProgress byte
// Store sets the value of the Value to x.
// All calls to Store for a given Value must use values of the same concrete type.
// Store of an inconsistent type panics, as does Store(nil).
func (v *Value) Store(val any) {
if val == nil {
panic("sync/atomic: store of nil value into Value")
}
vp := (*ifaceWords)(unsafe.Pointer(v))
vlp := (*ifaceWords)(unsafe.Pointer(&val))
for {
typ := LoadPointer(&vp.typ)
if typ == nil {
// Attempt to start first store.
// Disable preemption so that other goroutines can use
// active spin wait to wait for completion.
runtime_procPin()
if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(&firstStoreInProgress)) {
runtime_procUnpin()
continue
}
// Complete first store.
StorePointer(&vp.data, vlp.data)
StorePointer(&vp.typ, vlp.typ)
runtime_procUnpin()
return
}
if typ == unsafe.Pointer(&firstStoreInProgress) {
// First store in progress. Wait.
// Since we disable preemption around the first store,
// we can wait with active spinning.
continue
}
// First store completed. Check type and overwrite data.
if typ != vlp.typ {
panic("sync/atomic: store of inconsistently typed value into Value")
}
StorePointer(&vp.data, vlp.data)
return
}
}
根据笔者的个人实践，atomic.Value 关于内存保护，线程池面试题定期指针数学更新的静态数据读取是绝佳的场景，主张看看 官方文档供给架构是什么意思的 Copy On Write 完成。
这儿保护了一个 Map，每次插入 key 时直接线程安全创建一个新的 Map，经过 atomic.Value.S操作系统的主要功能是tore 赋值回来。读的时分用 atomic.Value.Load 转换成 Map 即可。
package main
import (
"sync"
"sync/atomic"
)
func main() {
type Map map[string]string
var m atomic.Value
m.Store(make(Map))
var mu sync.Mutex // used only by writers
// read function can be used to read the data without further synchronization
read := func(key string) (val string) {
m1 := m.Load().(Map)
return m1[key]
}
// insert function can be used to update the data without further synchronization
insert := func(key, val string) {
mu.Lock() // synchronize with other potential writers
defer mu.Unlock()
m1 := m.Load().(Map) // load current value of the data structure
m2 := make(Map) // create a new value
for 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 need
m.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
}
参照 COW
指针赋值是原子的么？
这个话题很有意思，感兴趣的同学能够看看在 wuyanyi指针是什么 大佬在 go-nu架构ts 的帖子，由于要不要加锁，和 weedfs 的作者以及B站的毛大都进行过评论：
- groups.google.com/g/golang-nu…
- github.com/Terry-Mao/g…
直接说定论，引用自鸟窝大神：
在现在的体系中，writ指针e 的地址基本上都是对齐的（aligned）。 比方，32 位的操作体系、CPU 以及编译器，write 的地址总是 4 的倍数，64 位的体系总是 8 的倍数操作系统有哪些（还记得 WaitGroup 针对 64 位体系和 32 位体系对 state1 的字段不同的处理吗）。对齐地址的写，不会导致其他人看到只写了一半的数据，架构师和程序员的区别由操作系统于它经过一个指令就能够完成对地址的操线程作。假如地址不是对齐的话，那么，处理器就需求分红两个指令去处指针说漫理，假如履指针说漫行了一个指令，其它人就会看到更架构师和程序员的区别新了一半线程数越多越好吗的过错的数据，这被称做撕裂写（torn write） 。所以，你能够以为赋值操作是一个原子操作，这个“原子操作”能够以为是确保数据的完整性。
可是，这并不代表 atomic 包没有意义，由于写归写，你写了纷歧定能被看到。线程是什么意思
由于 cache、指令重排，可见性等操作系统当前的配置不能运行此应用程序问题，咱们对原子操作的意义有了更多的追求。
在多核体系中，一个核对地址的值的更改，线程安全在更新到主内存中之前，是在多级缓存中存放的。这时，多个核看到的数据或许是纷歧样的，其它的核或许还没有看到更新的数据，还在使用旧的数据。
多处理器多核心体系为了处理指针数组这类问题，使用了一种叫做内存屏障（memory fen线程数是什么ce 或 memory barrier）的方法。一个写内存屏障会告诉处理器，有必要要比及它管道中的未完成的操作（特别是写操作）都被刷新到内存中，再进行操作。此操作还会让相关的处理器的 CPU 缓存失效，以便让它们从主存中拉取最新的值。
atomic 包供给的方法会供给内存屏障的功用，所以，a线程数是什么tomi指针万用表读数图解c 不仅仅能够确保赋值的数据完整性，还能确保数据的可见性，一线程是什么意思旦一个核更新了该地址的值，其它处理器总是能读取到它的最新值。可是，需求留意的是，由于需求处理器之间确保数据的一致性，atomic 的操作也是会降低功用的。
本文正在参加技术专题1线程的几种状态8期-聊聊Go语言结构
