校园春色亚洲色图_亚洲视频分类_中文字幕精品一区二区精品_麻豆一区区三区四区产品精品蜜桃

主頁 > 知識庫 > 快速解決Golang Map 并發(fā)讀寫安全的問題

快速解決Golang Map 并發(fā)讀寫安全的問題

熱門標簽:不封卡外呼系統(tǒng) 宿遷便宜外呼系統(tǒng)代理商 鄭州智能語音電銷機器人價格 上海極信防封電銷卡價格 地圖標注免費定制店 仙桃400電話辦理 湛江crm外呼系統(tǒng)排名 重慶慶云企業(yè)400電話到哪申請 寧波語音外呼系統(tǒng)公司

一、錯誤案例

package main
import (
	"fmt"
	"time"
)
var TestMap map[string]string
func init() {
	TestMap = make(map[string]string, 1)
}
func main() {
	for i := 0; i  1000; i++ {
		go Write("aaa")
		go Read("aaa")
		go Write("bbb")
		go Read("bbb")
	}
	time.Sleep(5 * time.Second)
}
func Read(key string) {
	fmt.Println(TestMap[key])
}
func Write(key string) {
	TestMap[key] = key
}

上面代碼執(zhí)行大概率出現報錯:fatal error: concurrent map writes

二、問題分析

網上關于 golang 編程中 map 并發(fā)讀寫相關的資料很多,但總是都說成 并發(fā)讀寫 造成上面的錯誤,到底是 并發(fā)讀 還是 并發(fā)寫 造成的,這個很多資料都沒有說明。

我們把上面的案例分別在循環(huán)中注釋 Read 和 Write 函數的調用,分別測試 并發(fā)讀 和 并發(fā)寫;

循環(huán)次數分別測試了 100、1 w、100 w 次,并發(fā)讀操作絕對不會報上面的錯,而并發(fā)寫基本都會報錯。

因此,這個錯誤主要原因是:map 并發(fā)寫。

三、問題原因

為什么 map 并發(fā)寫會導致這個錯誤? 網絡上的相關文章也大都有說明。

因為 map 變量為 指針類型變量,并發(fā)寫時,多個協程同時操作一個內存,類似于多線程操作同一個資源會發(fā)生競爭關系,共享資源會遭到破壞,因此golang 出于安全的考慮,拋出致命錯誤:fatal error: concurrent map writes。

四、解決方案

網上各路資料解決方案較多,主要思路是通過加鎖保證每個協程同步操作內存。

github 上找到一個 concurrentMap 包,案例代碼修改如下:

package main
import (
 "fmt"
 cmap "github.com/orcaman/concurrent-map"
 "time"
)
var TestMap cmap.ConcurrentMap
func init() {
 TestMap = cmap.New()
}
func main() {
 for i := 0; i  100; i++ {
 go Write("aaa", "111")
 go Read("aaa")
 go Write("bbb", "222")
 go Read("bbb")
 }
 time.Sleep(5 * time.Second)
}
func Read(key string) {
 if v, ok := TestMap.Get(key); ok {
 fmt.Printf("鍵值為 %s 的值為:%s", key, v)
 } else {
 fmt.Printf("鍵值不存在")
 }
}
func Write(key string, value string) {
 TestMap.Set(key, value)
}

五、思考總結

因為我是以 PHP 打開的編程世界,PHP 語言只有單線程,且不涉及指針操作,變量類型也是弱變量,以 PHP 編程思維剛開始接觸 Golang 時還比較容易上手,但越往后,語言的特性區(qū)別就體現得越來越明顯,思維轉變就越來越大,對我來說是打開了一個新世界。

像本文出現的錯誤案例,也是因為自己沒有多線程編程的思維基礎,導致對這種問題不敏感,還是花了蠻多時間理解的。希望對和我有相似學習路線的朋友提供到一些幫助。

補充:Golang Map并發(fā)處理機制(sync.Map)

Go語言中的Map在并發(fā)情況下,只讀是線程安全的,同時讀寫線程不安全。

示例:

package main 
import (
 "fmt"
)
var m = make(map[int]int)
func main() {
 //寫入操作
 i:=0
 go func() {
 for{
 i++
 m[1]=i
 }
 
 }()
 //讀操作
 go func() {
 for{
 fmt.Println(m[1])
 }
 
 }()
 //無限循環(huán),讓并發(fā)程序在后臺運行
 for {
 ;
 }
}

從以上示例可以看出,不斷地對map進行讀和寫,會出現錯誤。主要原因是對map進行讀和寫發(fā)生了競態(tài)問題。map內部會對這種并發(fā)操作進行檢查并提前發(fā)現。

如果確實需要對map進行并發(fā)讀寫操作,可以采用加鎖機制、channel同步機制,但這樣性能并不高。

Go語言在1.9版本中提供了一種效率較高的并發(fā)安全的sync.Map。

sync.Map結構如下:

The zero Map is empty and ready for use. A Map must not be copied after first use.
type Map struct {
 mu Mutex
 misses int
}
 
// Load returns the value stored in the map for a key, or nil if no
// value is present.
// The ok result indicates whether value was found in the map.
func (m *Map) Load(key interface{}) (value interface{}, ok bool) { 
}
 
// Store sets the value for a key.
func (m *Map) Store(key, value interface{}) {
 
}
// LoadOrStore returns the existing value for the key if present.
// Otherwise, it stores and returns the given value.
// The loaded result is true if the value was loaded, false if stored.
func (m *Map) LoadOrStore(key, value interface{}) (actual interface{}, loaded bool) { 
}
 
// Delete deletes the value for a key.
func (m *Map) Delete(key interface{}) { 
} 
 
// Range calls f sequentially for each key and value present in the map.
// If f returns false, range stops the iteration.
//
// Range does not necessarily correspond to any consistent snapshot of the Map's
// contents: no key will be visited more than once, but if the value for any key
// is stored or deleted concurrently, Range may reflect any mapping for that key
// from any point during the Range call.
//
// Range may be O(N) with the number of elements in the map even if f returns
// false after a constant number of calls.
func (m *Map) Range(f func(key, value interface{}) bool) { 
}
 
func (m *Map) missLocked() {
 
}
 
func (m *Map) dirtyLocked() {
 
}

其實,sync.Map內部還是進行了加鎖機制,不過進行了一定的優(yōu)化。

sync.Map使用示例:

package main 
import (
 "fmt"
 "sync"
 "time"
)
 
var m1 sync.Map 
func main() {
 i := 0
 go func() {
 for {
 i++
 m1.Store(1, i)
 time.Sleep(1000)
 }
 }()
 go func() {
 for{
 time.Sleep(1000)
 fmt.Println(m1.Load(1))
 }
 
 }()
 for {
 ;
 }
}

成功運行效果如下:

以上為個人經驗,希望能給大家一個參考,也希望大家多多支持腳本之家。如有錯誤或未考慮完全的地方,望不吝賜教。

您可能感興趣的文章:
  • 關于golang高并發(fā)的實現與注意事項說明
  • 基于Golang 高并發(fā)問題的解決方案
  • 使用golang編寫一個并發(fā)工作隊列
  • golang 并發(fā)編程之生產者消費者詳解
  • Golang 并發(fā)以及通道的使用方式
  • 淺談golang并發(fā)操作變量安全的問題
  • golang中的并發(fā)和并行

標簽:海南 儋州 電子產品 安康 物業(yè)服務 遼寧 青海 西雙版納

巨人網絡通訊聲明:本文標題《快速解決Golang Map 并發(fā)讀寫安全的問題》,本文關鍵詞  快速,解決,Golang,Map,并發(fā),;如發(fā)現本文內容存在版權問題,煩請?zhí)峁┫嚓P信息告之我們,我們將及時溝通與處理。本站內容系統(tǒng)采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《快速解決Golang Map 并發(fā)讀寫安全的問題》相關的同類信息!
  • 本頁收集關于快速解決Golang Map 并發(fā)讀寫安全的問題的相關信息資訊供網民參考!
  • 推薦文章
    校园春色亚洲色图_亚洲视频分类_中文字幕精品一区二区精品_麻豆一区区三区四区产品精品蜜桃
    国产乱子伦一区二区三区国色天香| 日韩国产成人精品| 亚洲欧洲国产日韩| 国产在线不卡一区| 91啪在线观看| 69成人精品免费视频| 国产三区在线成人av| 亚洲精品乱码久久久久久黑人 | 精品一区二区精品| 成熟亚洲日本毛茸茸凸凹| 欧美偷拍一区二区| 另类小说视频一区二区| 国产亚洲va综合人人澡精品| 精品久久久久久久一区二区蜜臀| 国产免费观看久久| 肉肉av福利一精品导航| 成人成人成人在线视频| 欧美日韩国产综合一区二区三区 | 国产无人区一区二区三区| 亚洲图片欧美色图| 99精品国产一区二区三区不卡| 在线播放中文一区| 亚洲黄色小视频| 成人综合婷婷国产精品久久| 亚洲国产日日夜夜| 亚洲国产精品成人综合| 亚洲国产综合91精品麻豆| 国产精品亚洲一区二区三区妖精| 欧美日韩综合在线| 亚洲精品日产精品乱码不卡| 国产精品香蕉一区二区三区| 日韩欧美黄色影院| 精品一区二区在线视频| 中文字幕亚洲在| 免费在线观看成人| 日韩欧美高清一区| 久久精品国产77777蜜臀| 色综合一区二区| 亚洲一区二区三区中文字幕| 777久久久精品| 免费国产亚洲视频| 国产日产亚洲精品系列| 国产精品亚洲专一区二区三区| 中文字幕五月欧美| 欧美国产日本视频| 99久久er热在这里只有精品66| 激情伊人五月天久久综合| 精品电影一区二区三区| 精品无人区卡一卡二卡三乱码免费卡 | 一本久久精品一区二区| 一区二区三国产精华液| 国产亚洲一区二区在线观看| 成人在线综合网站| 五月天激情综合| 国产精品高潮久久久久无| 色8久久人人97超碰香蕉987| 经典三级视频一区| 精品一区二区三区香蕉蜜桃| 欧美一区二区三区免费在线看| 精品一区二区免费看| 日韩毛片视频在线看| 欧美日韩精品一区二区天天拍小说 | 国产精品一级二级三级| 另类人妖一区二区av| 一区二区日韩电影| 中文字幕在线播放不卡一区| 欧美一区二区三区在线观看| 91色porny在线视频| 丁香五精品蜜臀久久久久99网站 | 美女久久久精品| 午夜精品福利在线| 1000精品久久久久久久久| 国产三级欧美三级| 欧美色国产精品| 色94色欧美sute亚洲线路二| 成人福利视频网站| 97久久超碰国产精品| 91蜜桃传媒精品久久久一区二区| 丰满白嫩尤物一区二区| 在线欧美日韩国产| 日韩一区二区三区视频| 亚洲欧美怡红院| 婷婷久久综合九色综合绿巨人 | 欧美日高清视频| 欧美精品一区二区久久久| 国产精品久久毛片av大全日韩| 国产欧美日韩卡一| 国产精品丝袜久久久久久app| 中文字幕精品一区| 一区二区三区欧美日韩| 亚洲综合精品自拍| 日本不卡一区二区| 久久国产精品99久久久久久老狼| 久久精品国产亚洲高清剧情介绍 | 中文字幕欧美一区| 免费人成精品欧美精品| 日韩欧美亚洲国产另类| 国产人久久人人人人爽| 亚洲va天堂va国产va久| 黄色日韩网站视频| 色综合视频在线观看| 精品国一区二区三区| 一区二区三区鲁丝不卡| 韩国一区二区视频| 欧美日韩电影在线| 国产无一区二区| 免费看精品久久片| 91国偷自产一区二区三区观看| 精品免费视频一区二区| 一区二区三区欧美久久| 国产精品一区三区| 国产一区二区三区在线观看免费视频 | 国产精品免费久久| 国产精品综合在线视频| 欧美巨大另类极品videosbest | 国产乱色国产精品免费视频| 91精品在线一区二区| 一区二区在线观看不卡| 99视频精品在线| 国产午夜亚洲精品不卡| 精品一区在线看| 日韩视频在线你懂得| 成人精品国产福利| 蜜桃av一区二区三区电影| 99久久99久久免费精品蜜臀| 久久天天做天天爱综合色| 美国十次综合导航| 日韩免费视频一区| 国内一区二区在线| 国产精品三级久久久久三级| 成人免费看的视频| 欧美成人欧美edvon| 国产尤物一区二区| 国产精品成人一区二区三区夜夜夜| 欧美日韩国产乱码电影| 奇米影视一区二区三区| 久久免费看少妇高潮| 国产成人av电影| 中文字幕高清一区| 欧美色中文字幕| 激情偷乱视频一区二区三区| 国产精品福利一区| 欧美高清激情brazzers| 国产一区二区三区精品欧美日韩一区二区三区| 欧美tickling网站挠脚心| 懂色av一区二区三区蜜臀| 亚洲国产成人tv| 久久久综合激的五月天| 欧美中文字幕一区二区三区亚洲| 日日欢夜夜爽一区| 欧美国产一区在线| 欧美一区二区黄色| 91成人国产精品| 成人午夜伦理影院| 蜜臀精品一区二区三区在线观看| 一区在线中文字幕| 欧美mv日韩mv国产网站app| 欧美艳星brazzers| 99久久99久久免费精品蜜臀| 国产又黄又大久久| 精品伊人久久久久7777人| 亚洲成va人在线观看| 亚洲少妇30p| 中文成人综合网| 国产欧美日韩视频在线观看| 国产欧美精品一区二区色综合朱莉| 欧美日韩二区三区| 欧美在线免费视屏| 欧美日韩在线播放三区| 欧美色精品天天在线观看视频| 在线区一区二视频| 欧美在线免费观看视频| 欧美亚洲动漫制服丝袜| 欧美久久一区二区| 日韩视频不卡中文| 久久亚洲欧美国产精品乐播| 国产午夜精品一区二区三区四区| 国产亚洲福利社区一区| 国产精品国产a| 一区二区三区在线免费播放| 亚洲一区二区视频在线观看| 亚洲午夜电影在线观看| 蜜臀国产一区二区三区在线播放| 久草在线在线精品观看| 国产黄色精品网站| 风流少妇一区二区| 欧美日韩成人在线| 国产精品色眯眯| 免费成人在线播放| 99精品在线免费| 日韩欧美精品三级| 一区二区视频在线| 久久99精品国产91久久来源| 99re8在线精品视频免费播放| 国产激情一区二区三区| 国产美女视频91| 欧美老人xxxx18| 亚洲色欲色欲www在线观看| 久久精品999| 欧美日韩一区小说|