我正试图操纵一个金刚sync.Map of sync.Map,但我对配角有一些问题。我有以下代码:
func (cluster *Cluster) action(object1, object2 MyObject) {
value, _ := cluster.globalMap.LoadOrStore(object1.name, sync.Map{})
localMap := value.(sync.Map)
localMap.Store(object2.Name, object2)
value2, _ := cluster.resourceInflight.Load(node.Name)
forComparison := value2.(sync.Map)
fmt.Println(localMap.Load(object2.Name))
fmt.Println(forComparison.Load(object2.Name))
}{myObject map[] map[]} true
<nil> false我这样做是因为我希望localMap线程的内容是安全的。
问题是,我希望我的两个打印结果相同,因为"forComparison“应该指向与"localMap”相同的对象。但第二个结果是零。
我怀疑问题来自于将接口“值”转换为实际的"sync.Map“。但是,我不知道如何使用内联转换来实际调用.Store方法。
我曾考虑过将localMap存储在cluster.globalMap中,但这在我看来是不正确的,因为它会破坏使用localSyncMap的全部意义,并造成并发问题。
对我该做什么有什么意见吗?
发布于 2022-02-21 03:38:38
根据注释,问题在于您正在复制一个sync.Map;以下代码将失败(输出“未找到”- 游乐场):
var sm sync.Map
var x interface{}
x = sm
sm2 := x.(sync.Map)
sm2.Store("test", "test")
result, ok := sm.Load("test")
if ok {
fmt.Printf("Found: %s\n", result)
} else {
fmt.Printf("Not found\n")
}而使用指针的工作原理是预期的:
var sm sync.Map
var x interface{}
x = &sm
sm2 := x.(*sync.Map)
sm2.Store("test", "test")
result, ok := sm.Load("test")
if ok {
fmt.Printf("Found: %s\n", result)
} else {
fmt.Printf("Not found\n")
}运行go vet可能会提醒您注意其他问题(sync.Map包含一个sync.Mutex,这些“不能在第一次使用后复制”)。
请注意,用于Sync.Map状态的文档:
Map类型是专门化的。大多数代码应该使用普通的Go映射,使用单独的锁定或协调,以获得更好的类型安全性,并使维护其他不变量和映射内容变得更容易。
https://stackoverflow.com/questions/71200609
复制相似问题