本文我們來學(xué)習(xí)一下golang里面的并發(fā)以及golang的鎖機(jī)制。
首先我們假設(shè)這樣一個(gè)場景灯谣,有兩個(gè)協(xié)程潜秋,同時(shí)在讀寫一個(gè)數(shù)字,分別對其進(jìn)行遞增和遞減胎许,代碼如下峻呛。
func main(){
a := 1
p_a := &a
go func(p_a *int){
for i := 1; i < 100000; i++ {
*p_a += 1
fmt.Println(*p_a)
}
}(p_a)
go func(p_a *int){
for i := 1; i < 100000; i++ {
*p_a -= 1
fmt.Println(*p_a)
}
}(p_a)
}
運(yùn)行這段代碼我們發(fā)現(xiàn)什么都沒有輸出,原因很簡單辜窑,主程序在創(chuàng)建完兩個(gè)協(xié)程之后就退出了钩述。要想讓主程序不退出可以使用sync.WaitGroup
func main(){
a := 1;
p_a := &a;
var wg sync.WaitGroup
wg.Add(2)
go func(p_a *int){
for i := 1; i < 100000; i++ {
*p_a += 1
}
wg.Done()
}(p_a)
go func(p_a *int){
for i := 1; i < 100000; i++ {
*p_a -= 1
}
wg.Done()
}(p_a)
wg.Wait()
fmt.Println(*p_a)
}
然而,程序跑出來的結(jié)果并不是1穆碎,而且每次跑出來的都不一樣牙勘。其實(shí),寫過一點(diǎn)并發(fā)的同學(xué)都知道原因惨远。假設(shè)當(dāng)前變量值為1谜悟,協(xié)程a試圖對其加1,于是協(xié)程a首先對其進(jìn)行讀操作北秽,得到1葡幸,并加1得到2,但是在2這個(gè)值被寫回變量之前贺氓,協(xié)程b讀取了變量蔚叨,而此時(shí)變量依舊還是1,于是b拿到這個(gè)1并減一得到0辙培。這時(shí)候蔑水,無論協(xié)程1先完成寫回還是協(xié)程b先完成寫回,我們得到的結(jié)果都是錯(cuò)的扬蕊。
要想得到正確的結(jié)果搀别,一個(gè)最常用的方法就是加鎖。在golang里面尾抑,我們可以使用sync.Mutex
var l sync.Mutex
func main(){
a := 1;
p_a := &a;
var wg sync.WaitGroup
wg.Add(2)
go func(p_a *int){
for i := 1; i < 100000; i++ {
l.Lock()
*p_a += 1
l.Unlock()
}
wg.Done()
}(p_a)
go func(p_a *int){
for i := 1; i < 100000; i++ {
l.Lock()
*p_a -= 1
l.Unlock()
}
wg.Done()
}(p_a)
wg.Wait()
fmt.Println(*p_a)
}
golang里面的map
當(dāng)一個(gè)協(xié)程在寫map的時(shí)候歇父,其他協(xié)程如果試圖去讀或者寫這個(gè)map,程序都會直接crash!!!很多人都在吐槽這個(gè)設(shè)計(jì)再愈,但是我覺得榜苫,這種設(shè)計(jì)至少給了程序員立即發(fā)現(xiàn)問題的機(jī)會。加鎖吧少年翎冲。
死鎖垂睬,活鎖與饑餓
死鎖可以理解為完成一項(xiàng)任務(wù)的資源被兩個(gè)(或多個(gè))不同的協(xié)程分別占用了,導(dǎo)致它們?nèi)继幱诘却隣顟B(tài)不能完成下去。
活鎖的例子是兩個(gè)或多個(gè)協(xié)程在執(zhí)行時(shí)分別占用了部分資源導(dǎo)致無法執(zhí)行驹饺。于是他們都釋放資源并重新請求钳枕,可是依舊碰撞,導(dǎo)致仍然無法執(zhí)行逻淌。
饑餓的例子是如果事務(wù)T1封鎖了數(shù)據(jù)R,事務(wù)T2又請求封鎖R么伯,于是T2等待。T3也請求封鎖R卡儒,當(dāng)T1釋放了R上的封鎖后田柔,系統(tǒng)首先批準(zhǔn)了T3的請求,T2仍然等待骨望。然后T4又請求封鎖R硬爆,當(dāng)T3釋放了R上的封鎖之后,系統(tǒng)又批準(zhǔn)了T4的請求......T2可能永遠(yuǎn)等待擎鸠。