我是否需要在从地图上删除该项目之前先上锁?
package main
import (
"errors"
"sync"
"time"
)
type A struct {
Error error
}
func (a *A) Job() {
// ... more job
}
var l sync.RWMutex
func generate() {
l.Lock()
values["key1"] = A{}
l.Unlock()
l.Lock()
values["key2"] = A{}
values["key3"] = A{}
l.Unlock()
// ...
l.Lock()
values["key1919"] = A{Error: errors.New("oh...")}
l.Unlock()
// ...
l.Lock()
values["key99999999999"] = A{}
l.Unlock()
}
var values map[string]A
func main() {
values = make(map[string]A)
go generate()
for {
l.RLock()
for key, value := range values {
if value.Error != nil {
delete(values, key) // it's safe? or you need to take a lock?
} else {
value.Job()
}
}
l.RUnlock()
time.Sleep(10 * time.Second)
}
}
变种:
范围内删除不用担心
在切片中添加键并单独范围以删除它们
l.RUNlock(); l.Lock();删除(值,键); l.解锁; l.RLock();在范围内
go l.delete(key) // gorutin 启动
哪个变体是通过锁定/解锁有效删除的?
从映射中删除被视为写入操作,并且必须与所有其他读取和写入序列化。如果我正确理解你的问题,那么是的,你需要稍后批量删除,或者放弃读锁并采取写锁来完成删除。
运行时尝试检测并发读取和写入,并将因以下原因之一而崩溃:
fatal error: concurrent map writes
fatal error: concurrent map read and map write
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系:hwhale#tublm.com(使用前将#替换为@)