Golang實現(xiàn)對map的并發(fā)讀寫的方法示例
更新時間：2019年03月11日 10:13:52 作者：hackssssss
這篇文章主要介紹了Golang實現(xiàn)對map的并發(fā)讀寫的方法示例，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
在Golang多協(xié)程的情況下使用全局map時，如果不做線程同步，會出現(xiàn)panic的情況。
為了解決這個問題，通常有兩種方式：
- 第一種是最常見的使用互斥鎖或者讀寫鎖的方法；
- 第二種是比較符合Golang特色的方法，啟動單個協(xié)程對map進(jìn)行讀寫，當(dāng)其他協(xié)程需要讀寫map時，通過channel向這個協(xié)程發(fā)送信號即可。
寫了一個模擬程序?qū)ap中的一項進(jìn)行讀或者寫，后臺一直運行的協(xié)程阻塞的接受讀寫信號，并對map進(jìn)行操作，但是讀操作的時候沒想好怎么返回這個值。
后來想到用傳引用的方式，定義結(jié)構(gòu)體，第一個參數(shù)是讀寫的標(biāo)志，第二個參數(shù)是讀成功或者寫成功后的值的channel，定義的channel中傳結(jié)構(gòu)體指針。
ps：以后驗證一下效率。簡單封裝了一下：http://chabaoo.cn/article/157620.htm
package main
import (
"fmt"
"strconv"
"time"
)
type value struct {
id int
op int
ret chan int
}
var dic map[int]int
var ch chan *value
func readAndWrite2Map() {
for {
select{
case flag := <- ch:
if flag.op > 0 {
log.Printf("id: %v, op: %v, ret: %v", flag.id, flag.op, flag.op)
dic[1] = flag.op
flag.ret <- dic[1]
} else if flag.op == 0 {
log.Printf("id: %v, op: %v, ret: %v", flag.id, flag.op, dic[1])
flag.ret <- dic[1]
} else {
return
}
}
}
}
func out(flag, i, val int) {
if flag == 0 {
fmt.Println(strconv.Itoa(i) + "th goroutine read the value is ", val)
} else {
fmt.Println(strconv.Itoa(i)+"th goroutine write to the map ", val)
}
}
func main() {
dic = make(map[int]int)
ch = make(chan *value)
dic[1] = -1
go readAndWrite2Map()
for i := 0; i <= 5; i++ {
if (i % 2) == 0 {
go func(i int) {
var tmp value
for {
tmp.op = 0
ch <- &tmp
out(0, i, <-tmp.ret)
time.Sleep(time.Millisecond)
}
}(i)
} else {
go func(i int) {
var tmp value
for {
tmp.op = i
ch <- &tmp
out(1, i, <-tmp.ret)
time.Sleep(time.Millisecond)
}
}(i)
}
}
time.Sleep(time.Second * 60)
}
以上就是本文的全部內(nèi)容，希望對大家的學(xué)習(xí)有所幫助，也希望大家多多支持腳本之家。
相關(guān)文章
golang標(biāo)準(zhǔn)庫有一個名叫encoding/json的包,包含了JSON的序列化(Marshal)和反序列化(Unmarshal)的能力,下面這篇文章主要給大家介紹了關(guān)于golang中json操作的相關(guān)資料,需要的朋友可以參考下2022-07-07
這篇文章主要為大家詳細(xì)介紹了Go語言中如何通過TCP協(xié)議實現(xiàn)聊天室功能,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-04-04
如何使用大學(xué)教育郵箱下載golang等軟件(推薦)
這篇文章主要介紹了如何使用大學(xué)教育郵箱下載goland等軟件,本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-09-09
這篇文章主要介紹了go語言睡眠排序算法,實例分析了睡眠排序算法的原理與實現(xiàn)技巧,需要的朋友可以參考下2015-03-03
go slice 擴(kuò)容實現(xiàn)原理源碼解析
這篇文章主要為大家介紹了go slice 擴(kuò)容實現(xiàn)原理源碼解析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2023-01-01
這篇文章主要介紹了Mac GoLand打不開(閃退)也不報錯的解決方案，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2021-04-04
這篇文章主要介紹了Go語言Mock使用基本指南詳解，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2020-06-06
這篇文章主要為大家介紹了Go Java算法之累加數(shù)示例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-08-08
開發(fā)中常會遇到需要比較兩個slice包含的元素是否完全相等的情況，我們通常會通過兩種方法去比較切片是否相等。這里通過幾個示例來看一下這兩種方法，感興趣的小伙伴們可以參考借鑒，希望對大家能有所幫助2022-11-11
這篇文章主要介紹了Go語言實現(xiàn)websocket推送程序，WebSocket是基于TCP的一個雙向傳輸數(shù)據(jù)的協(xié)議，和HTTP協(xié)議一樣，是在應(yīng)用層的，他的出現(xiàn)，是為了解決網(wǎng)頁進(jìn)行持久雙向傳輸數(shù)據(jù)的問題2023-01-01