日本免费高清视频-国产福利视频导航-黄色在线播放国产-天天操天天操天天操天天操|www.shdianci.com

學無先后，達者為師

網站首頁 編程語言 正文

GO語言臨界資源安全問題的深入理解_Golang

作者：Davie老師 ? 更新時間： 2021-12-06 編程語言

一、臨界資源

臨界資源: 指并發環境中多個進程/線程/協程共享的資源。

但是在并發編程中對臨界資源的處理不當， 往往會導致數據不一致的問題。

示例代碼：

package main
?
import (
    "fmt"
    "time"
)
?
func main()  {
    a := 1
    go func() {
        a = 2
        fmt.Println("子goroutine。。",a)
    }()
    a = 3
    time.Sleep(1)
    fmt.Println("main goroutine。。",a)
}

我們通過終端命令來執行：

能夠發現一處被多個goroutine共享的數據。

二、臨界資源安全問題

并發本身并不復雜，但是因為有了資源競爭的問題，就使得我們開發出好的并發程序變得復雜起來，因為會引起很多莫名其妙的問題。

如果多個goroutine在訪問同一個數據資源的時候，其中一個線程修改了數據，那么這個數值就被修改了，對于其他的goroutine來講，這個數值可能是不對的。

舉個例子，我們通過并發來實現火車站售票這個程序。一共有100張票，4個售票口同時出售。

我們先來看一下示例代碼：

package main
?
import (
    "fmt"
    "math/rand"
    "time"
)
?
//全局變量
var ticket = 10 // 100張票
?
func main() {
    /*
    4個goroutine，模擬4個售票口，4個子程序操作同一個共享數據。
     */
    go saleTickets("售票口1") // g1,100
    go saleTickets("售票口2") // g2,100
    go saleTickets("售票口3") //g3,100
    go saleTickets("售票口4") //g4,100
?
    time.Sleep(5*time.Second)
}
?
func saleTickets(name string) {
    rand.Seed(time.Now().UnixNano())
    //for i:=1;i<=100;i++{
    //  fmt.Println(name,"售出：",i)
    //}
    for { //ticket=1
        if ticket > 0 { //g1,g3,g2,g4
            //睡眠
            time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond)
            // g1 ,g3, g2,g4
            fmt.Println(name, "售出：", ticket)  // 1 , 0, -1 , -2
            ticket--   //0 , -1 ,-2 , -3
        } else {
            fmt.Println(name,"售罄，沒有票了。。")
            break
        }
    }
}
?

我們為了更好的觀察臨界資源問題，每個goroutine先睡眠一個隨機數，然后再售票，我們發現程序的運行結果，還可以賣出編號為負數的票。

分析：

我們的賣票邏輯是先判斷票數的編號是否為負數，如果大于0，然后我們就進行賣票，只不過在賣票錢先睡眠，然后再賣，假如說此時已經賣票到只剩最后1張了，某一個goroutine持有了CPU的時間片，那么它再片段是否有票的時候，條件是成立的，所以它可以賣票編號為1的最后一張票。但是因為它在賣之前，先睡眠了，那么其他的goroutine就會持有CPU的時間片，而此時這張票還沒有被賣出，那么第二個goroutine再判斷是否有票的時候，條件也是成立的，那么它可以賣出這張票，然而它也進入了睡眠。。其他的第三個第四個goroutine都是這樣的邏輯，當某個goroutine醒來的時候，不會再判斷是否有票，而是直接售出，這樣就賣出最后一張票了，然而其他的goroutine醒來的時候，就會陸續賣出了第0張，-1張，-2張。

這就是臨界資源的不安全問題。某一個goroutine在訪問某個數據資源的時候，按照數值，已經判斷好了條件，然后又被其他的goroutine搶占了資源，并修改了數值，等這個goroutine再繼續訪問這個數據的時候，數值已經不對了。

三、臨界資源安全問題的解決

要想解決臨界資源安全的問題，很多編程語言的解決方案都是同步。通過上鎖的方式，某一時間段，只能允許一個goroutine來訪問這個共享數據，當前goroutine訪問完畢，解鎖后，其他的goroutine才能來訪問。

我們可以借助于sync包下的鎖操作。

示例代碼：

package main
?
import (
    "fmt"
    "math/rand"
    "time"
    "sync"
)
?
//全局變量
var ticket = 10 // 100張票
?
var wg sync.WaitGroup
var matex sync.Mutex // 創建鎖頭
?
func main() {
    /*
    4個goroutine，模擬4個售票口，4個子程序操作同一個共享數據。
     */
    wg.Add(4)
    go saleTickets("售票口1") // g1,100
    go saleTickets("售票口2") // g2,100
    go saleTickets("售票口3") //g3,100
    go saleTickets("售票口4") //g4,100
    wg.Wait()              // main要等待。。。
?
    //time.Sleep(5*time.Second)
}
?
func saleTickets(name string) {
    rand.Seed(time.Now().UnixNano())
    defer wg.Done()
    //for i:=1;i<=100;i++{
    //  fmt.Println(name,"售出：",i)
    //}
    for { //ticket=1
        matex.Lock()
        if ticket > 0 { //g1,g3,g2,g4
            //睡眠
            time.Sleep(time.Duration(rand.Intn(1000)) * time.Millisecond)
            // g1 ,g3, g2,g4
            fmt.Println(name, "售出：", ticket) // 1 , 0, -1 , -2
            ticket--                         //0 , -1 ,-2 , -3
        } else {
            matex.Unlock() //解鎖
            fmt.Println(name, "售罄，沒有票了。。")
            break
        }
        matex.Unlock() //解鎖
    }
}
?

運行結果：

四、寫在最后

在Go的并發編程中有一句很經典的話：不要以共享內存的方式去通信，而要以通信的方式去共享內存。

在Go語言中并不鼓勵用鎖保護共享狀態的方式在不同的Goroutine中分享信息(以共享內存的方式去通信)。而是鼓勵通過channel將共享狀態或共享狀態的變化在各個Goroutine之間傳遞（以通信的方式去共享內存），這樣同樣能像用鎖一樣保證在同一的時間只有一個Goroutine訪問共享狀態。

當然，在主流的編程語言中為了保證多線程之間共享數據安全性和一致性，都會提供一套基本的同步工具集，如鎖，條件變量，原子操作等等。Go語言標準庫也毫不意外的提供了這些同步機制，使用方式也和其他語言也差不多。

原文鏈接：https://blog.csdn.net/qfzhangxu/article/details/107356601

欄目分類
最近更新