快捷導(dǎo)航

解析golang中的并發(fā)安全和鎖問題

更新時間：2021年11月08日 14:42:21 作者：專職

本文我們來學(xué)習(xí)一下golang中的并發(fā)安全和鎖問題，文章通過實例代碼給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值，需要的朋友參考下吧

1. 并發(fā)安全

package main
 
import (
    "fmt"
    "sync"
)
 
var (
    sum int
    wg sync.WaitGroup
)
 
func test() {
    for i := 0; i < 5000000; i++ {
        sum += 1
    }
    wg.Done()
}
 
func main() {
    // 并發(fā)和安全鎖
    wg.Add(2)
    go test()
    go test()
 
    wg.Wait()
    fmt.Println(sum)
 
}

　　上面的代碼中我們開啟了兩個goroutine去累加變量x的值，這兩個goroutine在訪問和修改x變量的時候就會存在數(shù)據(jù)競爭，導(dǎo)致最后的結(jié)果與期待的不符。

2. 互斥鎖

package main
 
import (
    "fmt"
    "sync"
)
 
var (
    sum int
    wg sync.WaitGroup
    mu sync.Mutex  // 定義一個互斥鎖
)
 
func test() {
    for i := 0; i < 10000000; i++ {
        // 互斥鎖它能夠保證同時只能有一個goroutine去訪問共享資源
        mu.Lock()
        sum += 1
        mu.Unlock()
    }
    wg.Done()
}
 
func main() {
    fmt.Println(mu)
    // 并發(fā)和安全鎖
    wg.Add(2)
    go test()
    go test()
 
    wg.Wait()
    fmt.Println(sum)
 
}

　　使用互斥鎖能夠保證同一時間有且只有一個goroutine進入臨界區(qū)，其他的goroutine則在等待鎖；當(dāng)互斥鎖釋放后，等待的goroutine才可以獲取鎖進入臨界區(qū)，多個goroutine同時等待一個鎖時，喚醒的策略是隨機的。

3. 讀寫互斥鎖

互斥鎖是完全互斥的，但是有很多實際的場景下是讀多寫少的，當(dāng)我們并發(fā)的去讀取一個資源不涉及資源修改的時候是沒有必要加鎖的，這種場景下使用讀寫鎖是更好的一種選擇。讀寫鎖在Go語言中使用sync包中的RWMutex類型。

讀寫鎖分為兩種：讀鎖和寫鎖。當(dāng)一個goroutine獲取讀鎖之后，其他的goroutine如果是獲取讀鎖會繼續(xù)獲得鎖，如果是獲取寫鎖就會等待；當(dāng)一個goroutine獲取寫鎖之后，其他的goroutine無論是獲取讀鎖還是寫鎖都會等待。

package main
 
import (
    "fmt"
    "sync"
    "time"
)
 
var (
    x int
    wg sync.WaitGroup
    mu sync.Mutex  // 定義一個互斥鎖
    rw sync.RWMutex  // 定義一個讀寫鎖，注意：只有讀多寫少的時候，讀寫鎖才能發(fā)揮其優(yōu)勢
)
 
func write() {
    rw.Lock()
    x += 1
    time.Sleep(10 * time.Millisecond)  // 假設(shè)寫入時間耗費10毫秒
    rw.Unlock()
    wg.Done()
}
func read() {
    rw.RLock()
    time.Sleep(time.Millisecond)
    rw.RUnlock()
    wg.Done()
}
 
func main() {
    start := time.Now()
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go write()
    }  // 寫耗時：160毫秒左右
 
    for i := 0; i < 1000; i++ {
        wg.Add(1)
        go read()
    }  // 讀耗時：15毫秒左右
 
    wg.Wait()
    end := time.Now()
    fmt.Println("執(zhí)行時間：", end.Sub(start))
}

　　需要注意的是讀寫鎖非常適合讀多寫少的場景，如果讀和寫的操作差別不大，讀寫鎖的優(yōu)勢就發(fā)揮不出來。

到此這篇關(guān)于golang中的并發(fā)安全和鎖的文章就介紹到這了,更多相關(guān)golang并發(fā)和鎖內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: