并发安全的切片映射

当前位置： > > > > 并发安全的切片映射

来源：stackoverflow
2024-04-24 10:15:32
0浏览
收藏

大家好，我们又见面了啊~本文《并发安全的切片映射》的内容中将会涉及到等等。如果你正在学习Golang相关知识，欢迎关注我，以后会给大家带来更多Golang相关文章，希望我们能一起进步！下面就开始本文的正式内容~

问题内容

我有一个包含 sync.map 的类型，其中映射中的键是字符串，值是切片。我将项目插入地图的代码如下：

newlist := []*item{item}
if result, ok := map.loadorstore(key, newlist); ok {
    resultlist := result.([]*item)
    resultlist = append(resultlist, item)
    map.store(key, resultlist)
}

这不是并发安全的，因为切片可以通过多个调用同时加载和修改。这段代码非常脆弱，所以我尝试将其修改为：

newlist := []*item{item}
if result, ok := map.loadorstore(key, &newlist); ok {
    resultlist := result.(*[]*item)
    *resultlist = append(*resultlist, item)
}

这一切都是为了让问题确定性地发生。因此，我正在尝试找到一种方法来获得可以同时添加的切片图。我的本能是在添加列表时使用 sync.mutex 来锁定列表，但为了保持对 sync.map 的并发访问，我还需要创建 sync.mutex 对象的映射，如下所示：

newLock := sync.Mutex{}
raw, _ := lockMap.LoadOrStore(key, &newLock)
lock := raw.(*sync.Mutex)

newList := []*Item{item}
if result, ok := map.LoadOrStore(key, &newList); ok {
    lock.Lock()
    resultList := result.(*[]*Item)
    *resultList = append(*resultList, item)
    lock.Unlock()
}

有没有更简单的方法来解决这个问题？

解决方案

这与您当前的计划没有太大不同，但您可以通过使用带有嵌入互斥锁的结构来存储映射的值，从而省去处理两个映射的麻烦。

结构看起来像这样：

type safeitems struct {
    sync.mutex
    items []*item
}

它可以这样使用：

newMapEntry := SafeItems{Items: itemPtrList}
if result, ok := map.LoadOrStore(key, &newMapEntry); ok {
    mapEntry := result.(*SafeItems)
    mapEntry.Lock()
    mapEntry.Items = append(mapEntry.Items, item)
    mapEntry.Unlock()
}

这并不是一个巨大的变化，但它确实提供了一些语法糖。

今天关于《并发安全的切片映射》的内容介绍就到此结束，如果有什么疑问或者建议，可以在公众号下多多回复交流；文中若有不正之处，也希望回复留言以告知！