Golang實(shí)現(xiàn)對(duì)map的并發(fā)讀寫的方法示例
在Golang多協(xié)程的情況下使用全局map時(shí),如果不做線程同步,會(huì)出現(xiàn)panic的情況。
為了解決這個(gè)問題,通常有兩種方式:
- 第一種是最常見的使用互斥鎖或者讀寫鎖的方法;
- 第二種是比較符合Golang特色的方法,啟動(dòng)單個(gè)協(xié)程對(duì)map進(jìn)行讀寫,當(dāng)其他協(xié)程需要讀寫map時(shí),通過channel向這個(gè)協(xié)程發(fā)送信號(hào)即可。
寫了一個(gè)模擬程序?qū)ap中的一項(xiàng)進(jìn)行讀或者寫,后臺(tái)一直運(yùn)行的協(xié)程阻塞的接受讀寫信號(hào),并對(duì)map進(jìn)行操作,但是讀操作的時(shí)候沒想好怎么返回這個(gè)值。
后來想到用傳引用的方式,定義結(jié)構(gòu)體,第一個(gè)參數(shù)是讀寫的標(biāo)志,第二個(gè)參數(shù)是讀成功或者寫成功后的值的channel,定義的channel中傳結(jié)構(gòu)體指針。
ps:以后驗(yàn)證一下效率。簡單封裝了一下:http://www.dbjr.com.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)容,希望對(duì)大家的學(xué)習(xí)有所幫助,也希望大家多多支持腳本之家。
相關(guān)文章
Go語言通過TCP協(xié)議實(shí)現(xiàn)聊天室功能
這篇文章主要為大家詳細(xì)介紹了Go語言中如何通過TCP協(xié)議實(shí)現(xiàn)聊天室功能,文中的示例代碼講解詳細(xì),感興趣的小伙伴可以跟隨小編一起學(xué)習(xí)一下2024-04-04如何使用大學(xué)教育郵箱下載golang等軟件(推薦)
這篇文章主要介紹了如何使用大學(xué)教育郵箱下載goland等軟件,本文給大家介紹的非常詳細(xì),對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-09-09go slice 擴(kuò)容實(shí)現(xiàn)原理源碼解析
這篇文章主要為大家介紹了go slice 擴(kuò)容實(shí)現(xiàn)原理源碼解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪2023-01-01Mac GoLand打不開(閃退)也不報(bào)錯(cuò)的解決方案
這篇文章主要介紹了Mac GoLand打不開(閃退)也不報(bào)錯(cuò)的解決方案,具有很好的參考價(jià)值,希望對(duì)大家有所幫助。一起跟隨小編過來看看吧2021-04-04Go語言實(shí)現(xiàn)websocket推送程序
這篇文章主要介紹了Go語言實(shí)現(xiàn)websocket推送程序,WebSocket是基于TCP的一個(gè)雙向傳輸數(shù)據(jù)的協(xié)議,和HTTP協(xié)議一樣,是在應(yīng)用層的,他的出現(xiàn),是為了解決網(wǎng)頁進(jìn)行持久雙向傳輸數(shù)據(jù)的問題2023-01-01