golang中并发编程的隔离性和可见性至关重要,以确保goroutine对共享数据的访问安全。隔离性使用互斥锁实现,确保一个goroutine在修改共享数据时,其他goroutine不能看到修改。可见性使用原子操作和内存屏障实现,确保所有goroutine都能看到已完成动作的结果。
GoLang 并发编程中的隔离性与可见性
引言
在GoLang中,并发编程涉及多个并发执行的Goroutine,有时称为轻量级线程。当Goroutine访问共享数据时,隔离性和可见性就变得至关重要。
隔离性
隔离性是指当一个Goroutine在修改共享数据时,其他Goroutine无法看到这些修改。GoLang使用互斥锁(mutexes)来实现隔离性。互斥锁是一种同步机制,允许Goroutine在一次只能有一个人访问共享数据的同时进行访问。
立即学习“go语言免费学习笔记(深入)”;
示例:
import (
"sync"
"fmt"
)
var count int
var mutex sync.Mutex
func increment() {
mutex.Lock()
count++
mutex.Unlock()
}
可见性
可见性是指所有Goroutine都能够看到已完成的动作的结果。GoLang使用atomicity和memory barriers来确保可见性。Atomicity意味着操作是不可分割的,在没有中断的情况下完成。
示例:
import (
"sync/atomic"
"fmt"
)
var counter int32
func increment() {
atomic.AddInt32(&counter, 1)
}
实战案例
任务: 多个Goroutine并发更新一个共享的计数器。
解决方案: 使用互斥锁来确保访问隔离性,并使用原子操作来确保可见性。
import (
"sync"
"sync/atomic"
"fmt"
)
var count int32
var mutex sync.Mutex
func increment() {
mutex.Lock()
count++
mutex.Unlock()
}
func atomicIncrement() {
atomic.AddInt32(&count, 1)
}
func main() {
wg := sync.WaitGroup{}
for i := 0; i < 100; i++ {
wg.Add(1)
// 使用互斥锁进行隔离
go func() {
increment()
wg.Done()
}()
// 使用原子操作进行可见性
go func() {
atomicIncrement()
wg.Done()
}()
}
wg.Wait()
fmt.Println(count)
}
在这种情况下,两个Goroutine可以使用互斥锁或原子操作并发更新共享的计数器,而不会发生数据竞争或不可预期的行为。