[TOC]
# 簡介
每個資源都對應一個可稱為"互斥鎖"的標記,這個標記用來保證在任意時刻,只有一個協程(線程)訪問該資源.其他的協程只能等待
由標準庫sync中的Mutex結構體類型表示.
`sync.Mutex`類型只有兩個公開的指針方法,Lock和Unlock.
Lock鎖定當前的共享資源,Unlock進行解鎖
使用互斥鎖時,一定要注意:對資源操作完成后,一定要解鎖,否則出現流程執行異常,死鎖問題.通常借助defer.鎖定后,立即使用defer語句保證互斥鎖及時解鎖
~~~
var mutex sync.Mutex //定義互斥鎖變量
func write() {
muter.Lock()
defer muter.Unlock()
}
~~~
# 使用
~~~
//新創建為0.表示沒有加鎖,鎖只有1把
var mutex sync.Mutex
func printer(str string) {
mutex.Lock()
for _, ch := range str {
fmt.Println(string(ch))
time.Sleep(300 * time.Millisecond)
}
//共享數據訪問結束
mutex.Unlock()
}
func person1() {
printer("11")
}
func person2() {
printer("222")
}
func main() {
//先,因為他先獲得鎖
go person1()
//后
go person2()
for {
;
}
}
~~~
# 不是強制性的
互斥鎖的使用是主動控制互斥鎖,即一個愿打一個愿挨。比如即使一個routine里用了Lock(),但在另一個routine可以不理會這個鎖就能訪問這個struct,只需要不調用Lock()就行。例子如下
~~~
package main
import (
"fmt"
"sync"
"time"
)
type SafeCounter struct {
v map[string]int
mux sync.Mutex
}
func (c *SafeCounter) Inc(key string) {
c.mux.Lock()
time.Sleep(3 * time.Second)
c.v[key]++
c.mux.Unlock()
}
func main() {
c := SafeCounter{v: make(map[string]int)}
go c.Inc("somekey")
time.Sleep(1 * time.Second)
c.v["somekey"]++
fmt.Println(c.v["somekey"])
time.Sleep(3 * time.Second)
fmt.Println(c.v["somekey"])
}
~~~
輸出
~~~
1
2
~~~
`c.v["somekey"]++`之前,是已經鎖了,本應該等2-3秒,才能輸出,但是從程序開始運行,只過了1秒就輸出了,說明Lock只是一種人為的互斥,是一種協議,并不是強制。
# 已經鎖定的Mutex與特定的goroutine無關聯
已經鎖定的Mutex并不與特定的goroutine相關聯,這樣可以利用一個goroutine對其加鎖,再利用其他goroutine對其解鎖,例子如下
~~~
package main
import (
"fmt"
"sync"
"time"
)
type MyStruct struct {
v int
mux sync.Mutex
}
func (s *MyStruct) Lock() {
s.mux.Lock()
}
func (s *MyStruct) Unlock() {
s.mux.Unlock()
}
func main() {
s := MyStruct{v: 0}
s.v = 1
fmt.Printf("%+v\n", s)
go s.Lock()
time.Sleep(1 * time.Second)
fmt.Printf("%+v\n", s)
go s.Unlock()
time.Sleep(1 * time.Second)
fmt.Printf("%+v\n", s)
}
~~~
輸出
~~~
{v:1 mux:{state:0 sema:0}}
{v:1 mux:{state:1 sema:0}}
{v:1 mux:{state:0 sema:0}}
~~~
可以看出,可以一個routine里鎖定,另一個routine里解鎖。因為鎖只和具體變量關聯,和routine無關,只要這個變量是共享的,比如通過指針傳遞,或者全局變量都可以。
雖然互斥鎖可以被直接的在多個Goroutine之間共享,但是我們還是強烈建議把對同一個互斥鎖的成對的鎖定和解鎖操作放在同一個層次的代碼塊中。例如,在同一個函數或方法中對某個互斥鎖的進行鎖定和解鎖。
- 基礎
- 簡介
- 主要特征
- 變量和常量
- 編碼轉換
- 數組
- byte與rune
- big
- sort接口
- 和mysql類型對應
- 函數
- 閉包
- 工作區
- 復合類型
- 指針
- 切片
- map
- 結構體
- sync.Map
- 隨機數
- 面向對象
- 匿名組合
- 方法
- 接口
- 權限
- 類型查詢
- 異常處理
- error
- panic
- recover
- 自定義錯誤
- 字符串處理
- 正則表達式
- json
- 文件操作
- os
- 文件讀寫
- 目錄
- bufio
- ioutil
- gob
- 棧幀的內存布局
- shell
- 時間處理
- time詳情
- time使用
- new和make的區別
- container
- list
- heap
- ring
- 測試
- 單元測試
- Mock依賴
- delve
- 命令
- TestMain
- path和filepath包
- log日志
- 反射
- 詳解
- plugin包
- 信號
- goto
- 協程
- 簡介
- 創建
- 協程退出
- runtime
- channel
- select
- 死鎖
- 互斥鎖
- 讀寫鎖
- 條件變量
- 嵌套
- 計算單個協程占用內存
- 執行規則
- 原子操作
- WaitGroup
- 定時器
- 對象池
- sync.once
- 網絡編程
- 分層模型
- socket
- tcp
- udp
- 服務端
- 客戶端
- 并發服務器
- Http
- 簡介
- http服務器
- http客戶端
- 爬蟲
- 平滑重啟
- context
- httptest
- 優雅中止
- web服務平滑重啟
- beego
- 安裝
- 路由器
- orm
- 單表增刪改查
- 多級表
- orm使用
- 高級查詢
- 關系查詢
- SQL查詢
- 元數據二次定義
- 控制器
- 參數解析
- 過濾器
- 數據輸出
- 表單數據驗證
- 錯誤處理
- 日志
- 模塊
- cache
- task
- 調試模塊
- config
- 部署
- 一些包
- gjson
- goredis
- collection
- sjson
- redigo
- aliyunoss
- 密碼
- 對稱加密
- 非對稱加密
- 單向散列函數
- 消息認證
- 數字簽名
- mysql優化
- 常見錯誤
- go run的錯誤
- 新手常見錯誤
- 中級錯誤
- 高級錯誤
- 常用工具
- 協程-泄露
- go env
- gometalinter代碼檢查
- go build
- go clean
- go test
- 包管理器
- go mod
- gopm
- go fmt
- pprof
- 提高編譯
- go get
- 代理
- 其他的知識
- go內存對齊
- 細節總結
- nginx路由匹配
- 一些博客
- redis為什么快
- cpu高速緩存
- 常用命令
- Go 永久阻塞的方法
- 常用技巧
- 密碼加密解密
- for 循環迭代變量
- 備注
- 垃圾回收
- 協程和纖程
- tar-gz
- 紅包算法
- 解決golang.org/x 下載失敗
- 逃逸分析
- docker
- 鏡像
- 容器
- 數據卷
- 網絡管理
- 網絡模式
- dockerfile
- docker-composer
- 微服務
- protoBuf
- GRPC
- tls
- consul
- micro
- crontab
- shell調用
- gorhill/cronexpr
- raft
- go操作etcd
- mongodb