在Go中同时访问带有“范围”的地图

您正在使用

for

range

范围表达式在开始循环之前先进行一次评估
，但有一个例外：如果范围表达式是一个数组或一个指向数组的指针，并且最多存在一个迭代变量，则仅评估范围表达式的长度；否则，不执行任何 *** 作。如果该长度是常数，则根据定义，范围表达式本身将不会被求值。

我们在地图上进行范围调整，因此也不例外：范围表达式在开始循环之前仅被评估一次。范围表达式只是一个map变量

testMap

for k, _ := range testMap {}

映射值不包括键值对，它仅 指向
包含键值对的数据结构。为什么这很重要？由于映射值仅被评估一次，并且如果以后添加了对，则在循环之前评估一次的映射值将成为仍然指向包含这些新对的数据结构的映射。这与对切片（也将被评估一次）的范围形成对比，切片也只是指向包含元素的后备数组的标头；但是如果在迭代过程中将元素添加到切片中，
_即使_如果那不会导致分配并复制到新的后备数组，则它们将不包含在迭代中（因为slice头还包含已评估的长度）。将元素追加到切片可能会产生新的切片值，但是将对添加到地图不会导致新的地图值。

现在开始迭代：

for k, v := range testMap {    t1 := time.Now()    someFunction()    t2 := time.Now()}

在进入块之前，

t1 := time.Now()

k

v

for ... range

t1

t2

someFunc()

for

someFunc()

for ...range

someFunc()

for

因此，要回答您的一个问题：

for

k

v

var (    testMap         = make(map[int]int)    testMapLock     = &sync.RWMutex{})func IterateMapKeys(iteratorChannel chan int) error {    testMapLock.RLock()    defer testMapLock.RUnlock()    for k, v := range testMap {        testMapLock.RUnlock()        someFunc()        testMapLock.RLock()        if someCond { return someErr        }    }    return nil}

请注意，解锁

IterateMapKeys()

if someCond {...}

还要注意，这种类型的锁定仅在并发访问的情况下才能确保锁定。 它不会阻止并发goroutine修改（例如添加新对）映射。
修改（如果使用写锁适当地保护）将是安全的，并且循环可以继续，但是不能保证for循环将在新对上进行迭代：

如果在迭代过程中删除尚未到达的映射条目，则不会生成相应的迭代值。如果映射条目是在迭代过程中创建的，则该条目可能在迭代过程中产生或可以被跳过。对于创建的每个条目以及从一个迭代到下一个迭代，选择可能有所不同。

写锁定保护的修改可能如下所示：

func WriteTestMap(k, v int) {    testMapLock.Lock()    defer testMapLock.Unlock()    testMap[k] = v}

现在，如果您在的代码块中释放了读取锁，则

for

testMapLock <- trueiteratorChannel <- k<-testMapLock

在上发送

k

iteratorChannel

总结一下最后一部分：释放

for

mySeq !=testMapSequence

package mainimport (    "fmt"    "math/rand"    "sync")var (    testMap         = make(map[int]int)    testMapLock     = &sync.RWMutex{}    testMapSequence int)func main() {    go func() {        for { k := rand.Intn(10000) WriteTestMap(k, 1)        }    }()    ic := make(chan int)    go func() {        for _ = range ic {        }    }()    for {        if err := IterateMapKeys(ic); err != nil { fmt.Println(err)        }    }}func WriteTestMap(k, v int) {    testMapLock.Lock()    defer testMapLock.Unlock()    testMap[k] = v    testMapSequence++}func IterateMapKeys(iteratorChannel chan int) error {    testMapLock.RLock()    defer testMapLock.RUnlock()    mySeq := testMapSequence    for k, _ := range testMap {        testMapLock.RUnlock()        iteratorChannel <- k        testMapLock.RLock()        if mySeq != testMapSequence { //close(iteratorChannel) return fmt.Errorf("concurrent modification %d", testMapSequence)        }    }    return nil}

输出示例：

concurrent modification 24concurrent modification 41concurrent modification 463concurrent modification 477concurrent modification 482concurrent modification 496concurrent modification 508concurrent modification 521concurrent modification 525concurrent modification 535concurrent modification 541concurrent modification 555concurrent modification 561concurrent modification 565concurrent modification 570concurrent modification 577concurrent modification 591concurrent modification 593

我们经常遇到并发修改！

您要避免这种并发修改吗？解决方案非常简单：请勿释放中的读取锁

for

-race

go run-race testmap.go

最后的想法

语言规范清楚地允许您 在同一goroutine 范围内修改地图，这就是前面的引用所涉及的内容（
“如果在迭代过程中删除了尚未到达的地图条目…。在迭代过程中创建…”
）。允许在同一goroutine中修改地图，这是安全的，但未定义迭代器逻辑如何处理地图。

如果在另一个goroutine中修改了映射，如果您使用适当的同步，则Go Memory
Model会保证带有的goroutine

for ...range