Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $YECBGYFECGEAFWHA as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2

Deprecated: imwpcache\f884414bce24ee67f\f73723ec7b1919fa5::__construct(): Implicitly marking parameter $BBWFDDBHHYHDXXAB as nullable is deprecated, the explicit nullable type must be used instead in /www/wwwroot/www.chuangxiangniao.com/wp-content/plugins/imwpcache-dist/build/f884414bce24ee67ff73723ec7b1919fa5.php on line 2
Golang并发map读写报错如何解决?Golang并发安全map使用方法_创想鸟

Golang并发map读写报错如何解决?Golang并发安全map使用方法

并发读写map在golang中会导致“fatal error: concurrent map read and map write”错误,解决方法是保证同一时间只有一个goroutine操作map。1. 使用互斥锁(mutex):通过sync.mutex实现读写加锁,简单但性能受限;2. 使用读写锁(rwmutex):读用rlock允许多个goroutine同时读,写用lock独占,适合读多写少场景;3. 使用sync.map:go 1.9内置并发安全map,适用于读多写少、key稳定及需原子操作的场景,但频繁写或遍历可能影响性能;4. 使用channel:通过专门goroutine处理map操作,实现细粒度控制但复杂度高。选择方案需考虑读写比例、key稳定性、性能要求和代码复杂度,不确定时可先用mutex再优化。

Golang并发map读写报错如何解决?Golang并发安全map使用方法

并发读写map,这个问题在Golang里确实挺常见的。直接操作内置的map,在多goroutine环境下,大概率会遇到“fatal error: concurrent map read and map write”这个报错。 这篇文章就来聊聊怎么解决这个问题,以及怎么安全地使用map。

Golang并发map读写报错如何解决?Golang并发安全map使用方法

解决方案

Golang并发map读写报错如何解决?Golang并发安全map使用方法

解决Golang并发map读写报错,核心思路就是保证在同一时间,只有一个goroutine可以修改map。有几种方法可以实现:

立即学习“go语言免费学习笔记(深入)”;

Golang并发map读写报错如何解决?Golang并发安全map使用方法

使用互斥锁(Mutex): 这是最直接也最常用的方法。用sync.Mutex来保护map的读写操作。

import (    "sync")type SafeMap struct {    mu sync.Mutex    data map[string]interface{}}func (sm *SafeMap) Load(key string) (interface{}, bool) {    sm.mu.Lock()    defer sm.mu.Unlock()    val, ok := sm.data[key]    return val, ok}func (sm *SafeMap) Store(key string, value interface{}) {    sm.mu.Lock()    defer sm.mu.Unlock()    sm.data[key] = value}

每次读写map之前,先Lock(),操作完之后Unlock()。 这种方法简单粗暴,但性能可能会受到影响,因为所有读写操作都要排队。

使用读写锁(RWMutex): 如果读操作远多于写操作,可以考虑使用sync.RWMutex。读锁允许多个goroutine同时读取map,但写锁会独占整个map。

import (    "sync")type SafeMap struct {    mu sync.RWMutex    data map[string]interface{}}func (sm *SafeMap) Load(key string) (interface{}, bool) {    sm.mu.RLock()    defer sm.mu.RUnlock()    val, ok := sm.data[key]    return val, ok}func (sm *SafeMap) Store(key string, value interface{}) {    sm.mu.Lock()    defer sm.mu.Unlock()    sm.data[key] = value}

RLock()用于读操作,Lock()用于写操作。 这样可以提高并发读取的性能。

使用sync.Map: Golang 1.9 之后,官方提供了一个并发安全的map,就是sync.Map。 它在内部使用了一些优化策略,比如读写分离,来提高并发性能。

import (    "sync")var sm sync.Mapfunc main() {    sm.Store("key1", "value1")    val, ok := sm.Load("key1")    if ok {        println(val.(string))    }}

sync.Map提供了一些方法,比如LoadStoreDeleteRange,用于安全地操作map。 需要注意的是,sync.Map更适合读多写少的场景。 如果写操作非常频繁,它的性能可能不如RWMutex

使用channel: 也可以使用channel来控制对map的访问。 创建一个goroutine专门负责map的读写操作,其他的goroutine通过channel向它发送请求。

type request struct {    key    string    value  interface{}    op     string // "load", "store", "delete"    respCh chan interface{}}func mapManager(data map[string]interface{}, reqCh <-chan request) {    for req := range reqCh {        switch req.op {        case "load":            val, ok := data[req.key]            req.respCh <- []interface{}{val, ok}        case "store":            data[req.key] = req.value            req.respCh <- nil        // ... other operations        }        close(req.respCh)    }}

这种方法可以实现更细粒度的控制,但也更复杂。

sync.Map的适用场景有哪些?

sync.Map的设计目标是解决特定场景下的并发安全问题。 它特别适合以下场景:

读多写少sync.Map针对读操作做了优化,所以在读多写少的场景下,性能会比较好。key相对稳定: 如果map的key相对稳定,不会频繁地添加或删除,sync.Map的性能会更好。需要原子操作sync.Map提供了一些原子操作,比如LoadOrStore,可以方便地实现一些复杂的逻辑。

在以下场景,sync.Map可能不是最佳选择:

写操作非常频繁: 如果写操作非常频繁,sync.Map的性能可能会下降。需要遍历所有keysync.MapRange方法在遍历时会加锁,如果map很大,遍历的性能可能会受到影响。

如何选择合适的并发map方案?

选择合适的并发map方案,需要综合考虑以下因素:

读写比例: 如果读多写少,sync.MapRWMutex可能更合适。 如果写操作非常频繁,Mutex可能更简单有效。key的稳定性: 如果key相对稳定,sync.Map可能更合适。 如果key会频繁地添加或删除,MutexRWMutex可能更灵活。性能要求: 如果对性能要求非常高,需要进行benchmark测试,选择性能最好的方案。代码复杂度MutexRWMutex使用起来比较简单,sync.Map和channel的方式可能更复杂。

总的来说,没有一种方案是万能的。 需要根据具体的场景,选择最合适的方案。 如果不确定,可以先使用Mutex,然后根据实际情况进行优化。

以上就是Golang并发map读写报错如何解决?Golang并发安全map使用方法的详细内容,更多请关注创想鸟其它相关文章!

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容, 请发送邮件至 chuangxiangniao@163.com 举报,一经查实,本站将立刻删除。
发布者:程序猿,转转请注明出处:https://www.chuangxiangniao.com/p/1389791.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
Go程序使用SQLite并发写入锁死怎么办
上一篇 2025年12月15日 08:53:53
Golang中如何实现测试功能 学习testing库的单元测试
下一篇 2025年12月15日 08:54:02

相关推荐

发表回复

登录后才能评论
关注微信