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進行讀寫,當其他協(xié)程需要讀寫map時,通過channel向這個協(xié)程發(fā)送信號即可。
寫了一個模擬程序?qū)ap中的一項進行讀或者寫,后臺一直運行的協(xié)程阻塞的接受讀寫信號,并對map進行操作,但是讀操作的時候沒想好怎么返回這個值。
后來想到用傳引用的方式,定義結(jié)構(gòu)體,第一個參數(shù)是讀寫的標志,第二個參數(shù)是讀成功或者寫成功后的值的channel,定義的channel中傳結(jié)構(gòu)體指針。
ps:以后驗證一下效率。簡單封裝了一下: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)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。

