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

主頁 > 知識庫 > golang中使用sync.Map的方法

golang中使用sync.Map的方法

熱門標簽:地圖標注測試 廣東語音外呼系統供應商 濮陽自動外呼系統代理 福州鐵通自動外呼系統 烏魯木齊人工電銷機器人系統 澳門防封電銷卡 智能電銷機器人營銷 長沙ai機器人電銷 賺地圖標注的錢犯法嗎

背景

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/

到此這篇關于golang中使用sync.Map的文章就介紹到這了,更多相關golang中使用sync.Map內容請搜索腳本之家以前的文章或繼續瀏覽下面的相關文章希望大家以后多多支持腳本之家!

您可能感興趣的文章:
  • 深度解密 Go 語言中的 sync.map
  • golang中sync.Map并發創建、讀取問題實戰記錄
  • Go 并發讀寫 sync.map 詳細

標簽:廣西 貴陽 德州 調研邀請 阿克蘇 太原 慶陽 西雙版納

巨人網絡通訊聲明:本文標題《golang中使用sync.Map的方法》,本文關鍵詞  golang,中,使用,sync.Map,的,;如發現本文內容存在版權問題,煩請提供相關信息告之我們,我們將及時溝通與處理。本站內容系統采集于網絡,涉及言論、版權與本站無關。
  • 相關文章
  • 下面列出與本文章《golang中使用sync.Map的方法》相關的同類信息!
  • 本頁收集關于golang中使用sync.Map的方法的相關信息資訊供網民參考!
  • 推薦文章
    主站蜘蛛池模板: 瑞安市| 临夏县| 兖州市| 吴旗县| 郴州市| 汉源县| 家居| 文水县| 黑河市| 鄂伦春自治旗| 垫江县| 阜平县| 民县| 贡嘎县| 阜新| 鹤岗市| 旌德县| 临澧县| 开鲁县| 北碚区| 临沂市| 醴陵市| 张家港市| 汝州市| 延庆县| 楚雄市| 偃师市| 甘德县| 邵东县| 台北市| 鱼台县| 潮安县| 赤峰市| 岳西县| 普兰县| 腾冲县| 札达县| 汤阴县| 绵阳市| 利川市| 郸城县|