【问题标题】:Is it safe to be removed from map in a concurrent environment? In Golang在并发环境中从地图中删除是否安全?在戈朗
【发布时间】:2016-04-20 20:46:04
【问题描述】:

在从地图中移除项目之前,我是否会锁定?

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)
    }
}

变体:

  1. 在范围内删除而不用担心

  2. 在切片中添加键并分隔范围以删除它们

  3. l.RUnlock(); l.Lock();删除(值,键); l.解锁; l.RLock();范围内

  4. go l.delete(key) // gorutin splash

哪个变体是使用锁定/解锁的有效删除?

【问题讨论】:

  • “竞争环境”=“并发环境”? “Die Konkurrenz”在德语中的意思是“竞争”(与并发无关),所以我想知道它在其他语言中是否也令人困惑。
  • 并发:)我从俄文翻译成英文的时候已经是深夜了:)俄文变体问题:toster.ru/q/313102

标签: go


【解决方案1】:

从映射中删除被视为写入操作,并且必须与所有其他读取和写入一起序列化。如果我正确理解您的问题,那么是的,您需要批量删除以备后用,或者放弃读锁并获取写锁以完成删除。

运行时尝试检测并发读取和写入,并会因以下原因之一崩溃:

fatal error: concurrent map writes
fatal error: concurrent map read and map write

【讨论】:

  • 我想了解如何以最合理的方式移除对象并避免不必要的锁定。垃圾对象的 GC :)
猜你喜欢
  • 2014-06-07
  • 1970-01-01
  • 2015-11-26
  • 1970-01-01
  • 2020-11-21
  • 2017-05-05
  • 1970-01-01
  • 2021-10-27
  • 2016-05-08
相关资源
最近更新 更多