教程集 www.jiaochengji.com
教程集 >  Golang编程  >  golang教程  >  正文 go语言坑之并发访问map

go语言坑之并发访问map

发布时间:2022-02-19   编辑:jiaochengji.com
教程集为您提供go语言坑之并发访问map等资源,欢迎您收藏本站,我们将为您提供最新的go语言坑之并发访问map资源
<svg xmlns="http://www.w3.org/2000/svg" style="display: none;"><path stroke-linecap="round" d="M5,0 0,2.5 5,5z" id="raphael-marker-block" style="-webkit-tap-highlight-color: rgba(0, 0, 0, 0);"/></svg>

go提供了一种叫map的数据结构,可以翻译成映射,对应于其他语言的字典、哈希表。借助map,可以定义一个键和值,然后可以从map中获取、设置和删除这个值,尤其适合数据查找的场景。但是map的使用有一定的限制,如果是在单个协程中读写map,那么不会存在什么问题,如果是多个协程并发访问一个map,有可能会导致程序退出,并打印下面错误信息:

<pre class="prettyprint"><code class=" hljs perl">fatal error: concurrent <span class="hljs-keyword">map</span> <span class="hljs-keyword">read</span> <span class="hljs-keyword">and</span> <span class="hljs-keyword">map</span> <span class="hljs-keyword">write</span></code></pre>

上面的这个错误不是每次都会遇到的,如果并发访问的协程数不大,遇到的可能性就更小了。例如下面的程序:

<pre class="prettyprint"><code class=" hljs go"><span class="hljs-keyword">package</span> main <span class="hljs-keyword">func</span> main() { Map := <span class="hljs-built_in">make</span>(<span class="hljs-keyword">map</span>[<span class="hljs-typename">int</span>]<span class="hljs-typename">int</span>) <span class="hljs-keyword">for</span> i :=<span class="hljs-number"> 0</span>; i <<span class="hljs-number"> 10</span>; i { <span class="hljs-keyword">go</span> writeMap(Map, i, i) <span class="hljs-keyword">go</span> readMap(Map, i) } } <span class="hljs-keyword">func</span> readMap(Map <span class="hljs-keyword">map</span>[<span class="hljs-typename">int</span>]<span class="hljs-typename">int</span>, key <span class="hljs-typename">int</span>) <span class="hljs-typename">int</span> { <span class="hljs-keyword">return</span> Map[key] } <span class="hljs-keyword">func</span> writeMap(Map <span class="hljs-keyword">map</span>[<span class="hljs-typename">int</span>]<span class="hljs-typename">int</span>, key <span class="hljs-typename">int</span>, value <span class="hljs-typename">int</span>) { Map[key] = value }</code></pre>

只循环了10次,产生了20个协程并发访问map,程序基本不会出错,但是如果将循环次数变大,比如10万,运行下面程序基本每次都会出错:

<pre class="prettyprint"><code class=" hljs go"><span class="hljs-keyword">package</span> main <span class="hljs-keyword">func</span> main() { Map := <span class="hljs-built_in">make</span>(<span class="hljs-keyword">map</span>[<span class="hljs-typename">int</span>]<span class="hljs-typename">int</span>) <span class="hljs-keyword">for</span> i :=<span class="hljs-number"> 0</span>; i <<span class="hljs-number"> 100000</span>; i { <span class="hljs-keyword">go</span> writeMap(Map, i, i) <span class="hljs-keyword">go</span> readMap(Map, i) } } <span class="hljs-keyword">func</span> readMap(Map <span class="hljs-keyword">map</span>[<span class="hljs-typename">int</span>]<span class="hljs-typename">int</span>, key <span class="hljs-typename">int</span>) <span class="hljs-typename">int</span> { <span class="hljs-keyword">return</span> Map[key] } <span class="hljs-keyword">func</span> writeMap(Map <span class="hljs-keyword">map</span>[<span class="hljs-typename">int</span>]<span class="hljs-typename">int</span>, key <span class="hljs-typename">int</span>, value <span class="hljs-typename">int</span>) { Map[key] = value } </code></pre>

go官方博客有如下说明:

<blockquote>

Maps are not safe for concurrent use: it’s not defined what happens when you read and write to them simultaneously. If you need to read from and write to a map from concurrently executing goroutines, the accesses must be mediated by some kind of synchronization mechanism. One common way to protect maps is with sync.RWMutex.

</blockquote>

go FAQ解释如下:

<blockquote>

After long discussion it was decided that the typical use of maps did not require safe access from multiple goroutines, and in those cases where it did, the map was probably part of some larger data structure or computation that was already synchronized. Therefore requiring that all map operations grab a mutex would slow down most programs and add safety to few. This was not an easy decision, however, since it means uncontrolled map access can crash the program.

</blockquote>

大致意思就是说,并发访问map是不安全的,会出现未定义行为,导致程序退出。所以如果希望在多协程中并发访问map,必须提供某种同步机制,一般情况下通过读写锁sync.RWMutex实现对map的并发访问控制,将map和sync.RWMutex封装一下,可以实现对map的安全并发访问,示例代码如下:

<pre class="prettyprint"><code class=" hljs go"><span class="hljs-keyword">package</span> main <span class="hljs-keyword">import</span> <span class="hljs-string">"sync"</span> <span class="hljs-keyword">type</span> SafeMap <span class="hljs-keyword">struct</span> { sync.RWMutex Map <span class="hljs-keyword">map</span>[<span class="hljs-typename">int</span>]<span class="hljs-typename">int</span> } <span class="hljs-keyword">func</span> main() { safeMap := newSafeMap<span class="hljs-number">(10</span>) <span class="hljs-keyword">for</span> i :=<span class="hljs-number"> 0</span>; i <<span class="hljs-number"> 100000</span>; i { <span class="hljs-keyword">go</span> safeMap.writeMap(i, i) <span class="hljs-keyword">go</span> safeMap.readMap(i) } } <span class="hljs-keyword">func</span> newSafeMap(size <span class="hljs-typename">int</span>) *SafeMap { sm := <span class="hljs-built_in">new</span>(SafeMap) sm.Map = <span class="hljs-built_in">make</span>(<span class="hljs-keyword">map</span>[<span class="hljs-typename">int</span>]<span class="hljs-typename">int</span>) <span class="hljs-keyword">return</span> sm } <span class="hljs-keyword">func</span> (sm *SafeMap) readMap(key <span class="hljs-typename">int</span>) <span class="hljs-typename">int</span> { sm.RLock() value := sm.Map[key] sm.RUnlock() <span class="hljs-keyword">return</span> value } <span class="hljs-keyword">func</span> (sm *SafeMap) writeMap(key <span class="hljs-typename">int</span>, value <span class="hljs-typename">int</span>) { sm.Lock() sm.Map[key] = value sm.Unlock() }</code></pre>

但是通过读写锁控制map的并发访问时,会导致一定的性能问题,不过能保证程序的安全运行,牺牲点性能问题是可以的。

<h3 id="参考">参考</h3>

go官方博客:https://blog.golang.org/go-maps-in-action

go FAQ:https://golang.org/doc/faq#atomic_maps

<h5 id="本次荐书买个好房子">本次荐书:买个好房子</h5>

到此这篇关于“go语言坑之并发访问map”的文章就介绍到这了,更多文章或继续浏览下面的相关文章,希望大家以后多多支持JQ教程网!

您可能感兴趣的文章:
go语言坑之并发访问map
golang 并发访问map遇到的问题
Go语言发展历史、核心、特性及学习路线
一道并发和锁的golang面试题
Go Map 简介 和 实现解析
Go基础学习三之数组array、切片slice、map
Go 开发关键技术指南 | 为什么你要选择 Go?(内含超全知识大图)
Golang 新手要注意的陷阱和常见错误(一)
Go语言基础、实战
「对比Python学习Go」- 高级数据结构下篇

上一篇:GO-基础 下一篇:MD5加密算法Golang实现
[关闭]
~ ~