Go并发编程之美-读写锁
生活随笔
收集整理的這篇文章主要介紹了
Go并发编程之美-读写锁
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
一、前言
go語言類似Java JUC包也提供了一些列用于多線程之間進行同步的措施,比如低級的同步措施有 鎖、CAS、原子變量操作類。相比Java來說go提供了獨特的基于通道的同步措施。本節我們先來看看go中讀寫鎖
二、讀寫鎖
go中讀寫鎖,在沒有線程獲取寫鎖情況下多個線程可以同時獲取讀鎖,讀鎖是可重入鎖,寫鎖則是互斥鎖(不可重入)。
package mainimport ("fmt""sync""time" )var (counter int //計數器wg sync.WaitGroup //信號量lock sync.RWMutex //讀寫鎖 )func main() {//1.兩個信號wg.Add(1)//2.獲取讀鎖fmt.Println("main thread wait rlock")lock.RLock()fmt.Println("main thread got rlock")//3.開啟子線程go incCounter()fmt.Println(counter)time.Sleep(time.Second * 5)//4.釋放讀鎖lock.RUnlock()fmt.Println("main thread release rlock")//5.等待子線程結束wg.Wait()fmt.Println(counter)}func incCounter() {defer wg.Done()//2.1.獲取鎖fmt.Println("sub thread wait rlock")lock.Lock()fmt.Println("sub thread got rlock")//2.2.計數加1counter++//2.3.釋放獨占鎖lock.Unlock()fmt.Println("sub thread relese rlock")}- 如上代碼go中使用sync.RWMutex可以獲取一個開箱即用的讀寫鎖
- 代碼(2)主線程使用lock.RLock()獲取讀鎖,然后開啟了子線程(代碼3),然后在主線程持有讀鎖的情況下休眠了5s后釋放了鎖。
- 子線程在代碼2.1嘗試使用 lock.Lock()獲取寫鎖,由于主線程還沒釋放讀鎖,所以子線程阻塞到了這里,直到主線程休眠后執行代碼4釋放了讀鎖。
- 執行代碼會輸出:
這個例子說明了,當有線程獲取了讀鎖并沒釋放時候,獲取寫鎖的線程要等待。
另外使用下面方法可以驗證讀鎖是可重入鎖:
lock.RLock()lock.RLock()fmt.Println(counter)lock.RUnlock()lock.RUnlock()使用下面代碼可以驗證同一個線程的讀鎖,不能晉升為寫鎖:
lock.RLock()lock.Lock()fmt.Println(counter)lock.Unlock()lock.RUnlock()上面代碼執行會報錯:
三、總結
go中讀寫鎖中的讀鎖是可重入共享鎖,寫鎖是互斥鎖,讀鎖不能晉升為寫鎖。
總結
以上是生活随笔為你收集整理的Go并发编程之美-读写锁的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: SPIDR - 完美分割用户故事的五种简
- 下一篇: 手挽手带你学React:三档 React