Go 語言中的 map 在并發情況下,只讀是線程安全的,同時讀寫線程不安全。
下面來看下并發情況下讀寫 map 時會出現的問題,代碼如下:
~~~
package main
func main() {
//創建一個int到int映射
m := make(map[int]int)
//開啟一段并發代碼
go func() {
//不停對map進行寫入
for {
m[1] = 1
}
}()
//開啟一段并發代碼
go func() {
//不停對map進行讀取
for {
_ = m[1]
}
}()
for {
;
}
}
~~~
運行代碼會報錯,輸出如下:
~~~
fatal error: concurrent map read and map write
~~~
運行時輸出提示:并發的 map 讀寫。也就是說使用了兩個并發函數不斷地對 map 進行讀和寫而發生了競態問題。map 內部會對這種并發操作進行檢查并提前發現。
需要并發讀寫時,一般的做法是加鎖,但這樣性能并不高。Go 語言在 1.9 版本中提供了一種效率較高的并發安全的 sync.Map。sync.Map 和 map 不同,不是以語言原生形態提供,而是在 sync 包下的特殊結構。
sync.Map有以下特性:
* 無須初始化,直接聲明即可。
* sync.Map 不能使用 map 的方式進行取值和設置等操作,而是使用 sync.Map 的方法進行調用。Store 表示存儲,Load 表示獲取,Delete 表示刪除。
* 使用 Range 配合一個回調函數進行遍歷操作,通過回調函數返回內部遍歷出來的值。Range 參數中的回調函數的返回值功能是:需要繼續迭代遍歷時,返回 true;終止迭代遍歷時,返回 false。
~~~
package main
import (
"fmt"
"sync"
)
func main() {
var scene sync.Map
// 將鍵值對保存到sync.Map
scene.Store("greece", 97)
scene.Store("london", 100)
scene.Store("egypt", 200)
// 從sync.Map中根據鍵取值
fmt.Println(scene.Load("london"))
// 根據鍵刪除對應的鍵值對
scene.Delete("london")
// 遍歷所有sync.Map中的鍵值對
scene.Range(func(k, v interface{}) bool {
fmt.Println("iterate:", k, v)
return true
})
}
~~~
代碼輸出如下:
~~~
100 true
iterate: egypt 200
iterate: greece 97
~~~
代碼說明如下:
* 第 10 行,聲明 scene,類型為 sync.Map。注意,sync.Map 不能使用 make 創建。
* 第 13~15 行,將一系列鍵值對保存到 sync.Map 中,sync.Map 將鍵和值以 interface{} 類型進行保存。
* 第 18 行,提供一個 sync.Map 的鍵給 scene.Load() 方法后將查詢到鍵對應的值返回。
* 第 21 行,sync.Map 的 Delete 可以使用指定的鍵將對應的鍵值對刪除。
* 第 24 行,Range() 方法可以遍歷 sync.Map,遍歷需要提供一個匿名函數,參數為 k、v,類型為 `interface{}`,每次 Range() 在遍歷一個元素時,都會調用這個匿名函數把結果返回。
sync.Map 沒有提供獲取 map 數量的方法,替代方法是獲取時遍歷自行計算數量。sync.Map 為了保證并發安全有一些性能損失,因此在非并發情況下,使用 map 相比使用 sync.Map 會有更好的性能。
- 基礎
- 簡介
- 主要特征
- 變量和常量
- 編碼轉換
- 數組
- byte與rune
- big
- sort接口
- 和mysql類型對應
- 函數
- 閉包
- 工作區
- 復合類型
- 指針
- 切片
- map
- 結構體
- sync.Map
- 隨機數
- 面向對象
- 匿名組合
- 方法
- 接口
- 權限
- 類型查詢
- 異常處理
- error
- panic
- recover
- 自定義錯誤
- 字符串處理
- 正則表達式
- json
- 文件操作
- os
- 文件讀寫
- 目錄
- bufio
- ioutil
- gob
- 棧幀的內存布局
- shell
- 時間處理
- time詳情
- time使用
- new和make的區別
- container
- list
- heap
- ring
- 測試
- 單元測試
- Mock依賴
- delve
- 命令
- TestMain
- path和filepath包
- log日志
- 反射
- 詳解
- plugin包
- 信號
- goto
- 協程
- 簡介
- 創建
- 協程退出
- runtime
- channel
- select
- 死鎖
- 互斥鎖
- 讀寫鎖
- 條件變量
- 嵌套
- 計算單個協程占用內存
- 執行規則
- 原子操作
- WaitGroup
- 定時器
- 對象池
- sync.once
- 網絡編程
- 分層模型
- socket
- tcp
- udp
- 服務端
- 客戶端
- 并發服務器
- Http
- 簡介
- http服務器
- http客戶端
- 爬蟲
- 平滑重啟
- context
- httptest
- 優雅中止
- web服務平滑重啟
- beego
- 安裝
- 路由器
- orm
- 單表增刪改查
- 多級表
- orm使用
- 高級查詢
- 關系查詢
- SQL查詢
- 元數據二次定義
- 控制器
- 參數解析
- 過濾器
- 數據輸出
- 表單數據驗證
- 錯誤處理
- 日志
- 模塊
- cache
- task
- 調試模塊
- config
- 部署
- 一些包
- gjson
- goredis
- collection
- sjson
- redigo
- aliyunoss
- 密碼
- 對稱加密
- 非對稱加密
- 單向散列函數
- 消息認證
- 數字簽名
- mysql優化
- 常見錯誤
- go run的錯誤
- 新手常見錯誤
- 中級錯誤
- 高級錯誤
- 常用工具
- 協程-泄露
- go env
- gometalinter代碼檢查
- go build
- go clean
- go test
- 包管理器
- go mod
- gopm
- go fmt
- pprof
- 提高編譯
- go get
- 代理
- 其他的知識
- go內存對齊
- 細節總結
- nginx路由匹配
- 一些博客
- redis為什么快
- cpu高速緩存
- 常用命令
- Go 永久阻塞的方法
- 常用技巧
- 密碼加密解密
- for 循環迭代變量
- 備注
- 垃圾回收
- 協程和纖程
- tar-gz
- 紅包算法
- 解決golang.org/x 下載失敗
- 逃逸分析
- docker
- 鏡像
- 容器
- 數據卷
- 網絡管理
- 網絡模式
- dockerfile
- docker-composer
- 微服務
- protoBuf
- GRPC
- tls
- consul
- micro
- crontab
- shell調用
- gorhill/cronexpr
- raft
- go操作etcd
- mongodb