Go并發(fā)編程之Mutex是什么-創(chuàng)新互聯(lián)

這篇文章給大家分享的是有關(guān)Go 并發(fā)編程之 Mutex是什么的內(nèi)容。小編覺得挺實用的，因此分享給大家做個參考。一起跟隨小編過來看看吧。

成都創(chuàng)新互聯(lián)憑借在網(wǎng)站建設(shè)、網(wǎng)站推廣領(lǐng)域領(lǐng)先的技術(shù)能力和多年的行業(yè)經(jīng)驗，為客戶提供超值的營銷型網(wǎng)站建設(shè)服務(wù)，我們始終認(rèn)為：好的營銷型網(wǎng)站就是好的業(yè)務(wù)員。我們已成功為企業(yè)單位、個人等客戶提供了成都網(wǎng)站制作、成都網(wǎng)站設(shè)計服務(wù)，以良好的商業(yè)信譽(yù)，完善的服務(wù)及深厚的技術(shù)力量處于同行領(lǐng)先地位。

我們比較常見的大型項目的設(shè)計中都會出現(xiàn)并發(fā)訪問問題，并發(fā)就是為了解決數(shù)據(jù)的準(zhǔn)確性，保證同一個臨界區(qū)的數(shù)據(jù)只能被一個線程進(jìn)行操作，日常中使用到的并發(fā)場景也是很多的：

• 計數(shù)器：計數(shù)器結(jié)果不準(zhǔn)確；
• 秒殺系統(tǒng)：由于同一時間訪問量比較大，導(dǎo)致的超賣；
• 用戶賬戶異常：同一時間支付導(dǎo)致的賬戶透支；
• buffer 數(shù)據(jù)異常：更新 buffer 導(dǎo)致的數(shù)據(jù)混亂。

上面都是并發(fā)帶來的數(shù)據(jù)準(zhǔn)確性的問題，決絕方案就是使用互斥鎖，也就是今天并發(fā)編程中的所要描述的 Mutex 并發(fā)原語。

實現(xiàn)機(jī)制

互斥鎖 Mutex 就是為了避免并發(fā)競爭建立的并發(fā)控制機(jī)制，其中有個“臨界區(qū)”的概念。

在并發(fā)編程過程中，如果程序中一部分資源或者變量會被并發(fā)訪問或者修改，為了避免并發(fā)訪問導(dǎo)致數(shù)據(jù)的不準(zhǔn)確，這部分程序需要率先被保護(hù)起來，之后操作，操作結(jié)束后去除保護(hù)，這部分被保護(hù)的程序就叫做臨界區(qū)。

使用互斥鎖，限定臨界區(qū)只能同時由一個線程持有，若是臨界區(qū)此時被一個線程持有，那么其他線程想進(jìn)入到這個臨界區(qū)的時候，就會失敗或者等待釋放鎖，持有此臨界區(qū)的線程退出，其他線程才有機(jī)會獲得這個臨界區(qū)。

go mutex 臨界區(qū)示意圖

Mutex 是 Go 語言中使用最廣泛的同步原語，也稱為并發(fā)原語，解決的是并發(fā)讀寫共享資源，避免出現(xiàn)數(shù)據(jù)競爭 data race 問題。

基本使用

互斥鎖 Mutex 提供了兩個方法 Lock 和 Unlock：進(jìn)入到臨界區(qū)使用 Lock 方法加鎖，退出臨界區(qū)使用 Unlock 方法釋放鎖。

type Locker interface {
    Lock()
    Unlock()}func(m *Mutex)Lock()func(m *Mutex)Unlock()

當(dāng)一個 goroutine 調(diào)用 Lock 方法獲取到鎖后，其他 goroutine 會阻塞在 Lock 的調(diào)用上，直到當(dāng)前獲取到鎖的 goroutine 釋放鎖。

接下來是一個計數(shù)器的例子，是由 100 個 goroutine 對計數(shù)器進(jìn)行累加操作，最后輸出結(jié)果：

package mainimport (
    "fmt"
    "sync")func main() {
    var mu sync.Mutex
    countNum := 0

    // 確認(rèn)輔助變量是否都執(zhí)行完成
    var wg sync.WaitGroup    // wg 添加數(shù)目要和 創(chuàng)建的協(xié)程數(shù)量保持一致
    wg.Add(100)
    for i := 0; i < 100; i++ {
        go func() {
            defer wg.Done()
            for j := 0; j < 1000; j++ {
                mu.Lock()
                countNum++
                mu.Unlock()
            }
        }()
    }
    wg.Wait()
    fmt.Printf("countNum: %d", countNum)}

實際使用

很多時候 Mutex 并不是單獨使用的，而是嵌套在 Struct 中使用，作為結(jié)構(gòu)體的一部分，如果嵌入的 struct 有多個字段，我們一般會把 Mutex 放在要控制的字段上面，然后使用空格把字段分隔開來。

甚至可以把獲取鎖、釋放鎖、計數(shù)加一的邏輯封裝成一個方法。

package mainimport (
    "fmt"
    "sync")// 線程安全的計數(shù)器type Counter struct {
    CounterType int
    Name        string

    mu    sync.Mutex
    count uint64}// 加一方法func (c *Counter) Incr() {
    c.mu.Lock()
    defer c.mu.Unlock()
    c.count++}// 取數(shù)值方法 線程也需要受保護(hù)func (c *Counter) Count() uint64 {
    c.mu.Lock()
    defer c.mu.Unlock()
    return c.count}func main() {
    // 定義一個計數(shù)器
    var counter Counter    var wg sync.WaitGroup
    wg.Add(100)

    for i := 0; i < 100; i++ {
        go func() {
            defer wg.Done()
            for j := 0; j < 1000; j++ {
                counter.Incr()
            }
        }()
    }
    wg.Wait()

    fmt.Printf("%d\n", counter.Count())}

感謝各位的閱讀！關(guān)于Go 并發(fā)編程之 Mutex是什么就分享到這里了，希望以上內(nèi)容可以對大家有一定的幫助，讓大家可以學(xué)到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到吧！

名稱欄目：Go并發(fā)編程之Mutex是什么-創(chuàng)新互聯(lián)
本文鏈接：http://bm7419.com/article16/djhhgg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供外貿(mào)建站、網(wǎng)站建設(shè)、網(wǎng)站內(nèi)鏈、網(wǎng)頁設(shè)計公司、定制網(wǎng)站、Google

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)