微网站生成app万物识别扫一扫

常见的内存逃逸　？

setNx 是一个原子操作命令

golang中三种线程安全的MAP-CSDN博客

使用Go语言实现线程安全的Map_go map线程安全-CSDN博客

https://zhuanlan.zhihu.com/p/9651365604　　// 处理map 并发问题

使用sync.Mutex

sync.Mutex是一个互斥锁，可以保护一个临界区，确保同时只有一个goroutine可以访问这段代码。

package mainimport ("fmt""sync"
)type SafeMap struct {m    map[string]intlock sync.Mutex
}func NewSafeMap() *SafeMap {return &SafeMap{m: make(map[string]int),}
}func (sm *SafeMap) Set(key string, value int) {sm.lock.Lock() // 在修改map之前加锁sm.m[key] = valuesm.lock.Unlock() // 修改完成后解锁
}func (sm *SafeMap) Get(key string) (int, bool) {sm.lock.Lock() // 在读取map之前加锁value, exists := sm.m[key]sm.lock.Unlock() // 读取完成后解锁return value, exists
}func main() {sm := NewSafeMap()sm.Set("foo", 1)value, exists := sm.Get("foo")if exists {fmt.Println("Value:", value)} else {fmt.Println("Key not found")}
}

使用sync.RWMutex

sync.RWMutex是一个读写锁，允许多个goroutine同时读取map，但写入时需要独占访问。这通常在读取操作远多于写入操作时更为高效。

package mainimport ("fmt""sync"
)type SafeMap struct {m    map[string]intlock sync.RWMutex
}func NewSafeMap() *SafeMap {return &SafeMap{m: make(map[string]int),}
}func (sm *SafeMap) Set(key string, value int) {sm.lock.Lock() // 在修改map之前加锁（写锁）sm.m[key] = valuesm.lock.Unlock() // 修改完成后解锁（写锁）
}func (sm *SafeMap) Get(key string) (int, bool) {sm.lock.RLock() // 在读取map之前加读锁value, exists := sm.m[key]sm.lock.RUnlock() // 读取完成后解锁（读锁）return value, exists
}func main() {sm := NewSafeMap()sm.Set("foo", 1)value, exists := sm.Get("foo")if exists {fmt.Println("Value:", value)} else {fmt.Println("Key not found")}
}

注意事项：性能和选择使用场景

• 使用互斥锁（sync.Mutex）：适用于读和写操作大致平衡的场景。每次读或写操作都需要获取锁，可能会造成性能瓶颈。

• 使用读写锁（sync.RWMutex）：适用于读操作远多于写操作的场景。读操作可以并行进行，而写操作则需要独占访问。这通常能提供更好的性能。但也要注意，频繁的读操作也可能因为频繁的锁获取和释放而影响性能。因此，选择哪种锁取决于你的具体应用场景。 例如，如果你的应用主要是查询操作，那么使用读写锁通常更合适。如果你的应用主要是更新操作，那么使用互斥锁可能更合适。 总之，选择合适的工具并根据实际使用场景进行优化是非常重要的。

channel 处理并发问题：

// 这个是错误的：没有起到并发作用/*** 并发编程，map的线程安全性问题，使用互斥锁的方式*/
package mainimport ("sync""time""fmt"
)var data map[int]int = make(map[int]int)
var wgMap sync.WaitGroup = sync.WaitGroup{}
var muMap sync.Mutex = sync.Mutex{}func main() {// 并发启动的协程数量max := 10000wgMap.Add(max)time1 := time.Now().UnixNano()for i := 0; i < max; i++ {go modifySafe(i)}wgMap.Wait()time2 := time.Now().UnixNano()fmt.Printf("data len=%d, time=%d", len(data), (time2-time1)/1000000)
}// 线程安全的方法，增加了互斥锁
func modifySafe(i int) {//muMap.Lock()data[i] = i//muMap.Unlock()wgMap.Done()
}/*** 并发编程，map的线程安全性问题，使用channel的方式*/
package mainimport ("time""fmt"
)var dataCh map[int]int = make(map[int]int)
var chMap chan int = make(chan int)func main() {// 并发启动的协程数量max := 10000time1 := time.Now().UnixNano()for i := 0; i < max; i++ {go modifyByChan(i)}// 处理channel的服务chanServ(max)time2 := time.Now().UnixNano()fmt.Printf("data len=%d, time=%d", len(dataCh), (time2-time1)/1000000)
}
func modifyByChan(i int) {chMap <- i
}
// 专门处理chMap的服务程序
func chanServ(max int) {for {i := <- chMapdataCh[i] = iif len(dataCh) == max {return}}
}