《Go 語言併發之道》讀書筆記(三)

来源:https://www.cnblogs.com/dk168/archive/2022/11/17/16899871.html
-Advertisement-
Play Games

1. 擴容方案剖析 1.1 擴容問題 在項目初期,我們部署了三個資料庫A、B、C,此時資料庫的規模可以滿足我們的業務需求。為了將數據做到平均分配,我們在Service服務層使用uid%3進行取模分片,從而將數據平均分配到三個資料庫中。 如圖所示: 後期隨著用戶量的增加,用戶產生的數據信息被源源不斷的 ...


今天這篇筆記我們來學習鎖:互斥鎖(Mutex) 和 讀寫鎖(RWMutex)

互斥鎖(Mutex)

首先我們來看一段代碼,沒有加鎖的情況下,兩個goroutine同時修改一個變數,會發生什麼

func main() {
	var count int
	increment := func() {
		count++
		fmt.Printf(" Incrementing: %d \n", count)
	}

	decrement := func() {
		count--
		fmt.Printf(" Decrementing: %d \n", count)
	}

	var arithmetic sync.WaitGroup
	for i := 0; i <= 5; i++ {
		arithmetic.Add(1)
		go func() {
			defer arithmetic.Done()
			increment()
		}()
	}

	for i := 0; i <= 5; i++ {
		arithmetic.Add(1)
		go func() {
			defer arithmetic.Done()
			decrement()
		}()
	}

	arithmetic.Wait()
	fmt.Println("Arithmetic complete.")

}

上面的代碼定義了一個increment方法和一個decrement方法,他們都操作count變數, 然後各自啟動5個goutinue去調用這兩個方法。 結果如下所示

 Decrementing: 1 
 Incrementing: 2 
 Incrementing: 1
 Decrementing: 0
 Decrementing: -1
 Decrementing: -1
 Incrementing: 0
 Decrementing: -2
 Decrementing: -3
 Incrementing: -2
 Incrementing: -1
 Incrementing: 0
Arithmetic complete.

我們可以看到,結果是亂的,第一個decrementing 應該是-1,結果這裡輸出了1,第三個incrementing應該是3,結果輸出是1. 這樣的效果肯定不是我們期望的, 當多個goroutine共用一個變數的時候,我們需要加鎖,保證一次只有一個goroutine能夠拿到鎖。如下代碼


func main() {
	var count int
	var lock sync.Mutex

	increment := func() {
		lock.Lock()
		defer lock.Unlock()
		count++
		fmt.Printf(" Incrementing: %d \n", count)
	}

	decrement := func() {
		lock.Lock()
		defer lock.Unlock()
		count--
		fmt.Printf(" Decrementing: %d \n", count)
	}

	var arithmetic sync.WaitGroup
	for i := 0; i <= 5; i++ {
		arithmetic.Add(1)
		go func() {
			defer arithmetic.Done()
			increment()
		}()
	}

	for i := 0; i <= 5; i++ {
		arithmetic.Add(1)
		go func() {
			defer arithmetic.Done()
			decrement()
		}()
	}

	arithmetic.Wait()
	fmt.Println("Arithmetic complete.")

}

我們在方法中加了lock.Lock()和defer lock.Unlock(), 運行的效果如下圖

 Incrementing: 1 
 Incrementing: 2 
 Incrementing: 3
 Incrementing: 4
 Incrementing: 5
 Decrementing: 4
 Decrementing: 3
 Decrementing: 2
 Decrementing: 1
 Decrementing: 0
 Decrementing: -1
 Incrementing: 0

這樣的結果符合我們的預期, incrementing的時候和上一條比加了1, decrementing的時候和上一條比減少了1,代碼改動是有效的,這就是鎖的作用, 加鎖後保證一次只有一個goroutine訪問共用的變數。

讀寫鎖(RWMutex)

什麼是讀寫鎖呢? 讀寫鎖允許多個只讀操作並行進行,而寫操作會完全互斥。 還是使用上面的例子,假如我有個方法只是想讀取count的value,並不改變它,那麼我們就可以用RWMutex.
我們稍微改變下上面的代碼


func main() {
	var count int
	var lock sync.RWMutex

	increment := func() {
		lock.Lock()
		defer lock.Unlock()
		count++
		fmt.Printf(" Incrementing: %d \n", count)
	}

	decrement := func() {
		lock.Lock()
		defer lock.Unlock()
		count--
		fmt.Printf(" Decrementing: %d %d\n", count, time.Now().Nanosecond())

		time.Sleep(time.Second)
	}

	read := func() {
		lock.RLock()
		defer lock.RUnlock()
		fmt.Printf(" reading: %d  %d\n", count, time.Now().Nanosecond())
		time.Sleep(time.Second)
	}

	var arithmetic sync.WaitGroup
	for i := 0; i <= 5; i++ {
		arithmetic.Add(1)
		go func() {
			defer arithmetic.Done()
			increment()
		}()
	}

	for i := 0; i <= 5; i++ {
		arithmetic.Add(1)
		go func() {
			defer arithmetic.Done()
			decrement()
		}()
	}

	for i := 0; i <= 10; i++ {
		arithmetic.Add(1)
		go func() {
			defer arithmetic.Done()
			read()
		}()
	}

	arithmetic.Wait()
	fmt.Println("Arithmetic complete.")

}

兩個改動,將Mutex換成RWMutex, 增加了一個read方法,它只讀取count變數,它加鎖的方法是lock.RLock(), 同時我們故意加了time.Sleep(time.Second),讓read方法和decrement方法執行的時候,停頓一下。
執行結果如下所示

Incrementing: 1 
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 reading: 1  177230700
 Incrementing: 2 
 Incrementing: 3 
 Incrementing: 4
 Incrementing: 5
 Decrementing: 4 193430000
 Decrementing: 3 204475300
 Decrementing: 2 213426500
 Decrementing: 1 227715200
 Decrementing: 0 240186800
 Decrementing: -1 255299900
 Incrementing: 0 
Arithmetic complete.

我們可以看到read方法,幾個gorountine執行的時間幾乎一樣,他們都能拿到讀鎖,不會被阻塞, 而且它拿到了一個準確的當時的value. 而decrement方法,相同的代碼,我們使用的是寫鎖,不同的gorountine會鎖住,他們的執行時間會相差。 這就是讀寫鎖。
拿讀鎖我們還可以用RWMutex.RLocker()來拿到鎖對象sync.Locker。
書中還比較了一個RWMutex和Mutex的性能差異,
當Reader數量比較小(<8)時,RWMutex性能稍差
當Reader數量大於8小於65536的時候, RWMutex比Mutex快一倍
當Reader數量大於131072的時候,RWMutex又比Mutex稍慢
作者說RWMutex要比Mutex稍複雜,所以會有這樣的結果
作者在書中說:通常建議使用RWMutex,而不是Mutex, 因為它在邏輯上更合理。


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • Kafka 常見問題 一年將盡夜,萬里未歸人。 1、Kafka 簡介 Apache Kafka是一個分散式發佈 - 訂閱消息系統和一個強大的隊列, 可以處理大量的數據, 並使您能夠將消息從一個端點傳遞到另一個端點。 Kafka適合離線和線上消息消費,Kafka消息保留在磁碟上, 併在群集內複製以防止 ...
  • 上篇文章介紹了編寫 Yarn Application 的整體框架流程,本篇文章將詳細介紹其中 Client 部分的編寫方式。 一、Yarn Client 編寫方法 本篇代碼已上傳 Github: Github - MyYarnClient 一)編寫流程 1、創建並啟動 Client YarnClie ...
  • 1.1 Java8的概述 Java8於2014年3月發佈,該版本是 Java 語言的一個重要版本,自Java5以來最具革命性的版本,該版本包含語言、編譯器、庫、工具和JVM等方面的多個新特性。 1.2 函數式介面 函數式介面主要指只包含一個抽象方法的介面,如:java.lang.Runnable等。 ...
  • 這篇文章主要介紹如何使用字元串來設置其他值的格式(比如便於列印),並大致瞭解使用字元串方法可完成的重要任務,如拆分、合併和查找等。 ...
  • 1 雲原生時代Java語言的困境 經過多年的演進,Java語言的功能和性能都在不斷的發展和提高,諸如即時編譯器、垃圾回收器等系統都能體現Java語言的優秀,但是想要享受這些功能帶來的提升都需要一段時間的運行來達到最佳性能,總的來說Java是面向大規模、長時間使用的服務端應用而設計的。 雲原生時代,J ...
  • 一、關鍵字和保留字 1.什麼是關鍵字? 通俗來說就是帶有特殊含義的字元,有自己專門用途的單詞 2.特點? 關鍵字全部由小寫構成,以下是java官方列舉出的關鍵字 註意: 保留關鍵字:指的是現有版本中尚未使用,後續可能會作為關鍵字使用,自己命名標識符要避免使用這些關鍵字,並且Java 的 null 不 ...
  • 前提:最近公司下發通知,所有開發人員 必須 卸載 Navicat 資料庫可視化工具,不知道兄弟們有沒有在使用的,可能現在的反應跟我一樣,一臉懵逼,Navicat為什麼不能使用呢? 有事沒事找度娘,於是我。。 (簡單粗暴) 搜到了答案。。 原來如此,那就廢話不多說,這邊介紹 使用 DBeaver 來替 ...
  • 作用:隨時修改代碼 (在函數或類定義完成之後,再去修改函數的實現過程) """類似猴子補丁在函數定義好之後,再去更改他的行為"""import typesclass Valley: def func(self): return "等待宣告"def common(self): return "只有永不 ...
一周排行
    -Advertisement-
    Play Games
  • Dapr Outbox 是1.12中的功能。 本文只介紹Dapr Outbox 執行流程,Dapr Outbox基本用法請閱讀官方文檔 。本文中appID=order-processor,topic=orders 本文前提知識:熟悉Dapr狀態管理、Dapr發佈訂閱和Outbox 模式。 Outbo ...
  • 引言 在前幾章我們深度講解了單元測試和集成測試的基礎知識,這一章我們來講解一下代碼覆蓋率,代碼覆蓋率是單元測試運行的度量值,覆蓋率通常以百分比表示,用於衡量代碼被測試覆蓋的程度,幫助開發人員評估測試用例的質量和代碼的健壯性。常見的覆蓋率包括語句覆蓋率(Line Coverage)、分支覆蓋率(Bra ...
  • 前言 本文介紹瞭如何使用S7.NET庫實現對西門子PLC DB塊數據的讀寫,記錄了使用電腦模擬,模擬PLC,自至完成測試的詳細流程,並重點介紹了在這個過程中的易錯點,供參考。 用到的軟體: 1.Windows環境下鏈路層網路訪問的行業標準工具(WinPcap_4_1_3.exe)下載鏈接:http ...
  • 從依賴倒置原則(Dependency Inversion Principle, DIP)到控制反轉(Inversion of Control, IoC)再到依賴註入(Dependency Injection, DI)的演進過程,我們可以理解為一種逐步抽象和解耦的設計思想。這種思想在C#等面向對象的編 ...
  • 關於Python中的私有屬性和私有方法 Python對於類的成員沒有嚴格的訪問控制限制,這與其他面相對對象語言有區別。關於私有屬性和私有方法,有如下要點: 1、通常我們約定,兩個下劃線開頭的屬性是私有的(private)。其他為公共的(public); 2、類內部可以訪問私有屬性(方法); 3、類外 ...
  • C++ 訪問說明符 訪問說明符是 C++ 中控制類成員(屬性和方法)可訪問性的關鍵字。它們用於封裝類數據並保護其免受意外修改或濫用。 三種訪問說明符: public:允許從類外部的任何地方訪問成員。 private:僅允許在類內部訪問成員。 protected:允許在類內部及其派生類中訪問成員。 示 ...
  • 寫這個隨筆說一下C++的static_cast和dynamic_cast用在子類與父類的指針轉換時的一些事宜。首先,【static_cast,dynamic_cast】【父類指針,子類指針】,兩兩一組,共有4種組合:用 static_cast 父類轉子類、用 static_cast 子類轉父類、使用 ...
  • /******************************************************************************************************** * * * 設計雙向鏈表的介面 * * * * Copyright (c) 2023-2 ...
  • 相信接觸過spring做開發的小伙伴們一定使用過@ComponentScan註解 @ComponentScan("com.wangm.lifecycle") public class AppConfig { } @ComponentScan指定basePackage,將包下的類按照一定規則註冊成Be ...
  • 操作系統 :CentOS 7.6_x64 opensips版本: 2.4.9 python版本:2.7.5 python作為腳本語言,使用起來很方便,查了下opensips的文檔,支持使用python腳本寫邏輯代碼。今天整理下CentOS7環境下opensips2.4.9的python模塊筆記及使用 ...