" />

亚洲乱码中文字幕综合,中国熟女仑乱hd,亚洲精品乱拍国产一区二区三区,一本大道卡一卡二卡三乱码全集资源,又粗又黄又硬又爽的免费视频

Golang的鎖機制與使用技巧小結(jié)

 更新時間:2022年06月01日 16:00:45   作者:樹獺叔叔  
本文主要介紹了Golang的鎖機制與使用技巧小結(jié),文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友們下面隨著小編來一起學習學習吧

1. sync.Mutex詳解

sync.Mutex是Go中的互斥鎖,通過.lock()方法上鎖,.unlock()方法解鎖。需要注意的是,因為Go函數(shù)值傳遞的特點,sync.Mutex通過函數(shù)傳遞時,會進行一次拷貝,所以傳遞過去的鎖是一把全新的鎖,大家在使用時要注意這一點,另外sync.Mutex是非重入鎖,這一點要與Java中的鎖區(qū)分。

type Mutex {
    state int32
    sema  uint32
}

上面數(shù)據(jù)結(jié)構(gòu)中的state最低三位分別表示 mutexLocked、mutexWoken 和 mutexStarving,剩下的位置用來表示當前有多少個 Goroutine 等待互斥鎖的釋放:

32                                               3             2             1             0 
 |                                               |             |             |             | 
 |                                               |             |             |             | 
 v-----------------------------------------------v-------------v-------------v-------------+ 
 |                                               |             |             |             v 
 |                 waitersCount                  |mutexStarving| mutexWoken  | mutexLocked | 
 |                                               |             |             |             | 
 +-----------------------------------------------+-------------+-------------+-------------+                                                                                                              
  • mutexLocked — 表示互斥鎖的鎖定狀態(tài);
  • mutexWoken — 表示從正常模式被從喚醒;
  • mutexStarving — 當前的互斥鎖進入饑餓狀態(tài);
  • waitersCount — 當前互斥鎖上等待的 goroutine 個數(shù);

2. RWMutex詳解

type RWMutex struct {
	w           Mutex  // 復用互斥鎖
	writerSem   uint32 // 寫鎖監(jiān)聽讀鎖釋放的信號量
	readerSem   uint32 // 讀鎖監(jiān)聽寫鎖釋放的信號量
	readerCount int32  // 當前正在執(zhí)行讀操作的數(shù)量
	readerWait  int32  // 當寫操作被阻塞時,需要等待讀操作完成的個數(shù)
}
  • 讀操作如何防止并發(fā)讀寫問題的?

RLock(): 申請讀鎖,每次執(zhí)行此函數(shù)后,會對readerCount++,此時當有寫操作執(zhí)行Lock()時會判斷readerCount>0,就會阻塞。

RUnLock(): 解除讀鎖,執(zhí)行readerCount–,釋放信號量喚醒等待寫操作的goroutine。

  • 寫操作如何防止并發(fā)讀寫、并發(fā)寫寫問題?

Lock(): 申請寫鎖,獲取互斥鎖,此時會阻塞其他的寫操作。并將readerCount 置為 -1,當有讀操作進來,發(fā)現(xiàn)readerCount = -1, 即知道有寫操作在進行,阻塞。

Unlock(): 解除寫鎖,會先通知所有阻塞的讀操作goroutine,然后才會釋放持有的互斥鎖。

  • 寫操作的饑餓問題?

這是由于寫操作要等待讀操作結(jié)束后才可以獲得鎖,而寫操作在等待期間可能還有新的讀操作持續(xù)到來,如果寫操作等待所有讀操作結(jié)束,很可能會一直阻塞,這種現(xiàn)象稱之為寫操作被餓死。

通過RWMutex結(jié)構(gòu)體中的readerWait屬性可完美解決這個問題。

當寫操作到來時,會把RWMutex.readerCount值拷貝到RWMutex.readerWait中,用于標記排在寫操作前面的讀者個數(shù)。

前面的讀操作結(jié)束后,除了會遞減RWMutex.readerCount,還會遞減RWMutex.readerWait值,當RWMutex.readerWait值變?yōu)?時喚醒寫操作。

3. sync.Map詳解

一般情況下解決并發(fā)讀寫 map 的思路是加一把大鎖,或者把一個 map 分成若干個小 map,對 key 進行哈希,只操作相應的小 map。前者鎖的粒度比較大,影響效率;后者實現(xiàn)起來比較復雜,容易出錯。

而使用 sync.map 之后,對 map 的讀寫,不需要加鎖。并且它通過空間換時間的方式,使用 read 和 dirty 兩個 map 來進行讀寫分離,降低鎖時間來提高效率。

type Map struct {
	mu Mutex
	read atomic.Value // readOnly
	dirty map[interface{}]*entry
	misses int
}

// readOnly is an immutable struct stored atomically in the Map.read field.
type readOnly struct {
	m       map[interface{}]*entry
	amended bool // true if the dirty map contains some key not in m.
}

type entry struct {
	p unsafe.Pointer // *interface{}
}

在進行讀操作的時候,會先在read中找,沒有命中的話會鎖住dirty并且尋找,如果找到了miss計數(shù)+1,超過閾值時將dirty賦值給read;

在進行添加操作時,直接在dirty中添加;

在進行修改操作時,先改read,再改dirty;

在進行刪除操作時,將read中加上amended標記,dirty中直接刪除。

4. 原子操作 atomic.Value

愿此操作的底層是靠 MESI 緩存一致性協(xié)議來維持的。

Go的 atomic.Value 需要注意應該放入只讀對象。

//atomic.Value源碼

type Value struct {
	v interface{} // 所以可以存儲任何類型的數(shù)據(jù)
}

// 空 interface{} 的內(nèi)部表示格式,作用是將interface{}類型分解,得到其中兩個字段
type ifaceWords struct {
	typ  unsafe.Pointer
	data unsafe.Pointer
}

// 取數(shù)據(jù)就是正常走流程
func (v *Value) Load() (x interface{}) {
	vp := (*ifaceWords)(unsafe.Pointer(v))
	typ := LoadPointer(&vp.typ)
	if typ == nil || uintptr(typ) == ^uintptr(0) {
		// 第一次還沒寫入
		return nil
	}
  // 構(gòu)造新的interface{}返回出去
	data := LoadPointer(&vp.data)
	xp := (*ifaceWords)(unsafe.Pointer(&x))
	xp.typ = typ
	xp.data = data
	return
}

// 寫數(shù)據(jù)(如何保證數(shù)據(jù)完整性)
func (v *Value) Store(x interface{}) {
	if x == nil {
		panic("sync/atomic: store of nil value into Value")
	}
  // 繞過 Go 語言類型系統(tǒng)的檢查,與任意的指針類型互相轉(zhuǎn)換
	vp := (*ifaceWords)(unsafe.Pointer(v)) // 舊值
	xp := (*ifaceWords)(unsafe.Pointer(&x)) // 新值
	for { // 配合CompareAndSwap達到樂觀鎖的功效
		typ := LoadPointer(&vp.typ)
		if typ == nil { // 第一次寫入
			runtime_procPin() // 禁止搶占
			if !CompareAndSwapPointer(&vp.typ, nil, unsafe.Pointer(^uintptr(0))) {
				runtime_procUnpin() // 沒有搶到鎖,說明已經(jīng)有別的線程搶先完成賦值,重新進入循環(huán)
				continue
			}
			// 首次賦值
			StorePointer(&vp.data, xp.data)
			StorePointer(&vp.typ, xp.typ)
			runtime_procUnpin() // 寫入成功,解除占用狀態(tài)
			return
		}
		if uintptr(typ) == ^uintptr(0) {
			// 第一次寫入還未完成,繼續(xù)等待
			continue
		}
		// 兩次需要寫入相同類型
		if typ != xp.typ {
			panic("sync/atomic: store of inconsistently typed value into Value")
		}
		StorePointer(&vp.data, xp.data)
		return
	}
}

// 禁止搶占,標記當前G在M上不會被搶占,并返回當前所在P的ID。
func runtime_procPin()
// 解除G的禁止搶占狀態(tài),之后G可被搶占。
func runtime_procUnpin()

5. 使用小技巧

  • 減小臨界區(qū)域(減少鎖的持有時間)
var m sync.Mutex

func DoSth() {
    // do sth1
    func() {
       u.lock()
       defer m.unlock()
       // do sth2
    }() 
    // do sth3
}

如上所示,如果do sth3中是很費時的io操作,使用這個技巧可以將臨界區(qū)減小,提高性能,不過,如果本身臨界區(qū)就不大,鎖操作后續(xù)沒有什么費時操作,那么也就沒有必要這樣操作了。

  • 減小鎖的粒度

在高并發(fā)場景下,用鎖的數(shù)量來換取并發(fā)效率,類似于java中ConcurrentHashmap的分段鎖思想,增加鎖的數(shù)量,減少一把鎖控制的數(shù)據(jù)量。

  • 讀寫分離(讀寫鎖): RWMutex,sync.Map

在讀多寫少的情景下,可以使用讀寫鎖,提高讀操作的并發(fā)性能。

  • 使用原子操作

原子操作是CPU指令級的操作,不會觸發(fā)g調(diào)度機制。,不阻塞執(zhí)行流

到此這篇關于Golang的鎖機制與使用技巧精選的文章就介紹到這了,更多相關Golang 鎖機制內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家!

相關文章

  • Beego AutoRouter工作原理解析

    Beego AutoRouter工作原理解析

    這篇文章主要為大家介紹了Beego AutoRouter工作原理解析,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進步,早日升職加薪
    2022-08-08
  • 一步步教你在Linux上安裝Go語言環(huán)境

    一步步教你在Linux上安裝Go語言環(huán)境

    本文將介紹如何在Linux操作系統(tǒng)下搭建Go語言環(huán)境,Go語言是一種開源的編程語言,具有高效、簡潔和并發(fā)性強的特點,適用于開發(fā)各種類型的應用程序,搭建Go語言環(huán)境是開始學習和開發(fā)Go語言項目的第一步,本文將詳細介紹安裝Go語言、配置環(huán)境變量以及驗證安裝是否成功的步驟
    2023-10-10
  • golang實現(xiàn)圖像驗證碼的示例代碼

    golang實現(xiàn)圖像驗證碼的示例代碼

    這篇文章主要為大家詳細介紹了如何利用golang實現(xiàn)簡單的圖像驗證碼,文中的示例代碼講解詳細,具有一定的學習價值,感興趣的小伙伴可以跟隨小編一起學習一下
    2023-10-10
  • Go?mod包管理工具詳解

    Go?mod包管理工具詳解

    Go?mod作為Go語言的官方包管理工具,可以幫助開發(fā)者更好地管理包和依賴,提高開發(fā)效率和項目可維護性,本文將介紹Go語言的包和依賴管理,以及Go?mod的作用和優(yōu)勢,需要的朋友可以參考下
    2023-05-05
  • Go依賴注入DI工具wire使用詳解(golang常用庫包)

    Go依賴注入DI工具wire使用詳解(golang常用庫包)

    依賴注入是指程序運行過程中,如果需要調(diào)用另一個對象協(xié)助時,無須在代碼中創(chuàng)建被調(diào)用者,而是依賴于外部的注入,本文結(jié)合示例代碼給大家介紹Go依賴注入DI工具wire使用,感興趣的朋友一起看看吧
    2022-04-04
  • Go語言學習之golang-jwt/jwt的教程分享

    Go語言學習之golang-jwt/jwt的教程分享

    jwt是?json?web?token的簡稱。go使用jwt目前,主流使用的jwt庫是golang-jwt/jwt。本文就來和大家講講golang-jwt/jwt的具體使用,需要的可以參考一下
    2023-01-01
  • 解決GOPATH在GOLAND中的坑

    解決GOPATH在GOLAND中的坑

    這篇文章主要介紹了解決GOPATH在GOLAND中的坑,具有很好的參考價值,希望對大家有所幫助。一起跟隨小編過來看看吧
    2020-12-12
  • 深入理解go sync.Once的具體使用

    深入理解go sync.Once的具體使用

    在很多情況下,我們可能需要控制某一段代碼只執(zhí)行一次,go 為我們提供了?sync.Once?對象,它保證了某個動作只被執(zhí)行一次,本文主要介紹了深入理解go sync.Once的具體使用,感興趣的可以了解一下
    2024-01-01
  • Gin框架自帶參數(shù)校驗的使用詳解

    Gin框架自帶參數(shù)校驗的使用詳解

    這篇文章主要為大家詳細介紹了如何使用Gin框架自帶的參數(shù)校驗,文中的示例代碼講解詳細,具有一定的學習價值,感興趣的小伙伴可以了解下
    2023-09-09
  • go語言import報錯處理圖文詳解

    go語言import報錯處理圖文詳解

    今天本來想嘗試一下go語言中公有和私有的方法,結(jié)果import其他包的時候直接報錯了,下面這篇文章主要給大家介紹了關于go語言import報錯處理的相關資料,需要的朋友可以參考下
    2023-04-04

最新評論