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)
 
}

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

2. 互斥鎖

package main
 
import (
    "fmt"
    "sync"
)
 
var (
    sum int
    wg sync.WaitGroup
    mu sync.Mutex  // 定義一個(gè)互斥鎖
)
 
func test() {
    for i := 0; i < 10000000; i++ {
        // 互斥鎖它能夠保證同時(shí)只能有一個(gè)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)
 
}

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

3. 讀寫互斥鎖

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

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

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

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

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

您可能感興趣的文章: