[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