golang中使用sync.Map的方法
作者:IT技术小小鸟 发布时间:2024-02-08 13:50:40
标签:golang,sync.Map
背景
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://www.jb51.net/article/188788.htm
参考
https://www.kancloud.cn/liupengjie/go/718991
https://colobu.com/2017/07/11/dive-into-sync-Map/
来源:https://www.cnblogs.com/vwvwvwgwg/p/13069899.html
0
投稿
猜你喜欢
- 比如 1--1 2--1  
- 用Python实现点对点的聊天,2个程序,一个是client.py,一个是server.py,通过本机地址127.0.0.1连接进行通信,利
- 前面是分部讲解,完整代码在最后。导入模块 :import osfrom shutil import copy, rmtreeimport r
- 1. 图片验证码1.1 工具类-utility.py将所有和图片验证码有关的方法放在类 ImageCodeimport randomimpo
- 前言最近在数据库的一张表添加两个字段,后来提示什么磁盘空间不足什么什么的,后来数据库就断开连接了,之后就一直连接不上去后来,最后经过思考终于
- 如下所示:#!/usr/bin/python#-*- coding: utf-8 -*-fin=open('add_1.txt
- 本文实例为大家分享了Python Opencv基于透视变换的图像矫正,供大家参考,具体内容如下一、自动获取图像顶点变换(获取图像轮廓顶点矫正
- Pygal可用来生成可缩放的矢量图形文件,对于需要在尺寸不同的屏幕上显示的图表,这很有用,可以自动缩放,自适应观看者的屏幕1、Pygal模块
- 前言这篇博客针对《PPython+Qt身体特征识别人数统计》编写代码,功能包括了相片,摄像头身体识别,数量统计。代码整洁,规则,易读。应用推
- print(X.shape):查看矩阵的行列号print(len(X)):查看矩阵的行数print(X.ndim):查看矩阵的维数1 查看矩
- python用正则表达式提取中文Python re正则匹配中文,其实非常简单,把中文的unicode字符串转换成utf-8格式就可以了,然后
- 1、编写TCP服务器程序。2、获取浏览器发送的http请求消息数据。3、读取固定的页面数据,将页面数据组装成HTTP响应消息数据并发送给浏览
- 先来看段mysql查询文章回复语句:#查询文章回复-- ------------------------------ Procedure s
- 一、HACK以下两种方法几乎能解决现今所有HACK。1, !important 随着IE7对!important的支持, !imp
- 事件调度sched 模块内容很简单,只定义了一个类。它用来最为一个通用的事件调度模块。class sched.scheduler(timef
- 本文实例讲述了Python接收Gmail新邮件并发送到gtalk的方法。分享给大家供大家参考。具体实现方法如下:#!/usr/bin/env
- 一、简介 Python的条件和循环语句,决定了程序的控制流程,体现结构的多样性。
- 在输入框里面预设一段提示文字,当焦点在输入框的时候清空这段文字,这在目前来说已经不是什么新鲜事了。淘宝的搜索框就用到了这样一种设计:这种设计
- listlist是一种有序的集合,可以随时添加和删除其中的元素。跟java不一样的是 可以使用arr[-1] 0>-x >=-
- 项目地址:https://github.com/jrainlau/wallpaper-downloader前言好久没有写文章了,因为最近都在