我要评论背景
go中map数据结构不是线程安全的，即多个goroutine同时操作一个map，则会报错，因此go1.9之后诞生了sync.map
sync.map思路来自java的concurrenthashmap
接口
sync.map就是1.9版本带的线程安全map，主要有如下几种方法：
load(key interface{}) (value interface{}, ok bool)
//通过提供一个键key，查找对应的值value，如果不存在，则返回nil。ok的结果表示是否在map中找到值
store(key, value interface{})
//这个相当于是写map（更新或新增），第一个参数是key，第二个参数是value
loadorstore(key, value interface{}) (actual interface{}, loaded bool)
//通过提供一个键key，查找对应的值value，如果存在返回键的现有值，否则存储并返回给定的值，如果是读取则返回true，如果是存储返回false
delete(key interface{})
//通过提供一个键key，删除键对应的值
range(f func(key, value interface{}) bool)
//循环读取map中的值。
//因为for ... range map是内置的语言特性，所以没有办法使用for range遍历sync.map, 但是可以使用它的range方法，通过回调的方式遍
实践
package main
import (
"fmt"
"sync"
)
var num = 0
var addtest *addtest
func init() {
addtest = &addtest{}
}
type addtest struct {
m sync.mutex
}
func (at *addtest) increment(wg *sync.waitgroup) {
//互斥锁
at.m.lock() //当有线程进去进行加锁
num++
at.m.unlock() //出来后解锁，其他线程才可以进去
wg.done()
}
func (at *addtest) decrement(wg *sync.waitgroup) {
//互斥锁
at.m.lock() //当有线程进去进行加锁
num--
at.m.unlock() //出来后解锁，其他线程才可以进去
wg.done()
}
var w sync.waitgroup
var aa map[int]int
func main() {
var bb sync.map
var wg sync.waitgroup
//aa = make(map[int]int)
wg.add(2)
go func() {
//wg.add(1)
for i:=0 ;i <100; i++{
//aa[i] = i+1
//fmt.println("a")
bb.store(i, i+1)
}
wg.done()
}()
go func() {
for i:=0 ;i <100; i++{
//aa[i] = i+1
//fmt.println("a")
bb.store(i, i+1)
}
wg.done()
}()
wg.wait()
bb.range(func(k, v interface{}) bool {
fmt.println("iterate:", k, v)
return true
}
}
总结
- 读写锁和互斥锁 读写锁： 可以获取多个读锁，只有读写冲突(加了读锁的时候，其它线程不能写) 互斥锁：跟读写操作无关，加了锁，锁内的资源就线程独享
- 个人感觉使用起来不太方便，不如根据实际场景自己互斥锁。比如map都是可读的，只有写的时候需要串行执行，则写操作封装互斥锁即可
- sync.map因为内部的操作较多等原因，并不适合大量写的场景（适合大量读，少量写）。
- sync.map的原理详见：
参考
https://colobu.com/2017/07/11/dive-into-sync-map/
到此这篇关于golang中使用sync.map的文章就介绍到这了,更多相关golang中使用sync.map内容请搜索移动技术网以前的文章或继续浏览下面的相关文章希望大家以后多多支持移动技术网！
您可能感兴趣的文章:
如您对本文有疑问或者有任何想说的，请 点击进行留言回复，万千网友为您解惑！
网友评论