GO学习之 同步操作sync包

2023-11-05 05:28
文章标签 go 学习 sync 同步操作

本文主要是介绍GO学习之 同步操作sync包,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

GO系列

1、GO学习之Hello World
2、GO学习之入门语法
3、GO学习之切片操作
4、GO学习之 Map 操作
5、GO学习之 结构体 操作
6、GO学习之 通道(Channel)
7、GO学习之 多线程(goroutine)
8、GO学习之 函数(Function)
9、GO学习之 接口(Interface)
10、GO学习之 网络通信(Net/Http)
11、GO学习之 微框架(Gin)
12、GO学习之 数据库(mysql)
13、GO学习之 数据库(Redis)
14、GO学习之 搜索引擎(ElasticSearch)
15、GO学习之 消息队列(Kafka)
16、GO学习之 远程过程调用(RPC)
17、GO学习之 goroutine的调度原理
18、GO学习之 通道(nil Channel妙用)
19、GO学习之 同步操作sync包

文章目录

  • GO系列
  • 前言
  • 一、channel 和 sync包
    • 1.1 channel 和 sync包性能测试
    • 1.2 channel 和 sync包如何选择
  • 二、sync包使用注意事项
  • 三、sync.Mutex 原理
  • 四、小结

前言

按照公司目前的任务,go 学习是必经之路了,虽然行业卷,不过技多不压身,依旧努力!!!
同步操作在并发中是必不可少的的,若对一些公用的资源进行操作,为了保证操作的原子和一致性,就需要使用到锁来进行控制。
Go 语言在提供CSP(通信顺序进程)并发模型原语的的同时,还提供了标准库 sync包 针对传统基于共享内存并发模型的同步原语,包括 互斥锁(sync.Mutex)、读写锁(sync.RWMutex)、条件锁(sync.Cond)等。

一、channel 和 sync包

  • Go 语言提倡不要通过共享内存来通信,而是要通过通信来共享内存,一般的场景中,先使用 CSP 并发模型实现,就是 goroutine + channel 编程。但也有一些特殊的场景,需要 sync包 提供的低级同步原语。
  • 在 Go 中,channel 属于高级同步原语,其实现是建立在低级同步原语之上的,所以 channel 自身的性能与低级同步原语相比要稍微逊色一点了。因此,在需要需要高性能的情况下,sync包 提供的低同步原语更为重要。

1.1 channel 和 sync包性能测试

我们来对 channel 和 sync包 的性能做一个对比,示例代码如下(channel_sync_test.go ):
注意!!!

  1. 基准测试代码文件必须是_test.go结尾,和单元测试一样;
  2. 基准测试的函数以Benchmark开头;
  3. 参数为 *testing.B;
  4. 基准测试函数不能有返回值;
  5. b.ResetTimer是重置计时器,这样可以避免for循环之前的初始化代码的干扰;
  6. b.N是基准测试框架提供的,是循环次数,无需关心;
  7. go test -bench . .\channel_sync_test.go 运行;
package mainimport ("sync""testing"
)var data = 0// 声明互斥锁
var mu sync.Mutex// 声明一个通道
var ch = make(chan struct{}, 1)func syncByMutex() {mu.Lock()data++mu.Unlock()
}func syncByChannel() {ch <- struct{}{}data++<-ch
}// 基准测试函数以 Benchmark 开头
func BenchmarkSectionByMutex(b *testing.B) {for i := 0; i < b.N; i++ {syncByMutex()}
}// 基准测试函数以 Benchmark 开头
func BenchmarkSectionByChannel(b *testing.B) {for i := 0; i < b.N; i++ {syncByChannel()}
}

运行结果:

PS D:\workspaceGo\src\sync> go test -bench . .\channel_sync_test.go
goos: windows
goarch: amd64
cpu: Intel(R) Core(TM) i5-8300H CPU @ 2.30GHz
BenchmarkSectionByMutex-8       79662760                13.15 ns/op
BenchmarkSectionByChannel-8     27814993                40.38 ns/op
PASS
ok      command-line-arguments  2.523s

从运行结果中看,BenchmarkSectionByChannel 测试函数是 40.38 ns/opBenchmarkSectionByMutex13.15 ns/op,很明显 sync包 的的性能更佳。

1.2 channel 和 sync包如何选择

  • 同步访问 channel 的并发设计的特点是,在 goroutine 间通过 channel 转移数据对象的所有权。只有获得了数据对象的所有权(就是从 channel 中获得该对象)才可以对数据对象进行状态变更。
  • 如果设计中没有转移结构体对象所有权,但又要保证结构体内部状态能在多个 goroutine 之间同步,那么你可以使用 sync包 提供的低级同步原语来实现,比如 sync.Mutex(互斥锁)。

二、sync包使用注意事项

在 sync 包中,有这么些注释:

  • Values containing the types defined in this package should not be copied. (不应该包含那些包含了此包中类型的值)
  • A Mutex must not be copied after first use. (禁止复制首次使用后的 Mutex)

还有其他 sync包 中也有诸如此类注释,那是为什么呢?我们来进行一个小 demo:

package mainimport ("log""sync""time"
)// 声明一个结构体 data
type data struct {n intsync.Mutex
}func main() {// 声明一个结构体对象 dd := data{n: 100}// 启动一个线程进行加锁操作go func(d data) {for {log.Println("go 2 try to lock...")d.Lock()log.Println("go 2 locked ok...")time.Sleep(3 * time.Second)d.Unlock()log.Println("go 2 unlock ok...")}}(d)d.Lock()log.Println("go main lock ok...")// 在 Mutex 首次使用后复制值go func(d data) {log.Println("go 1 try lock...")d.Lock()log.Println("go 1 locked ok...")time.Sleep(3 * time.Second)d.Unlock()log.Println("go 1 unlock ok...")}(d)time.Sleep(1000 * time.Second)d.Unlock()log.Println("go main unlock ok...")
}

运行结果:

PS D:\workspaceGo\src\sync> go run .\sync.go
2023/11/04 16:57:24 go main lock ok...
2023/11/04 16:57:24 go 2 try to lock...
2023/11/04 16:57:24 go 2 locked ok...
2023/11/04 16:57:24 go 1 try lock...
2023/11/04 16:57:27 go 2 unlock ok...
2023/11/04 16:57:27 go 2 try to lock...
2023/11/04 16:57:27 go 2 locked ok...
2023/11/04 16:57:30 go 2 unlock ok...
2023/11/04 16:57:30 go 2 try to lock...
2023/11/04 16:57:30 go 2 locked ok...
...

在示例中创建了两个 goroutine :go 1 和 go 2,从运行结果中看到 go 1 阻塞在了加锁操作上了,则 go 2 则是按照预期正常运行。go 1 和 go 2 的区别就在于 go 2 是在互斥锁首次使用之前创建的,而 go 1 则是在互斥锁加锁操作并且在锁定状态之后创建的,并且程序在创建 go 1的时候复制了 data 的实例并且使用了这个副本。

三、sync.Mutex 原理

我们可以在 $GOROOT/src/sync/mutex.go 源码中看到如下声明语句:

type Mutex struct {state int32sema  uint32
}

其实 sync.Mutex 的实现很简单,定义了两个字段 state 和 sema。

  • state:表示当前互斥锁的状态
  • sema:用户控制状态的信号量

对Mutex实例的复制即是对两个整型字段的复制。在初始状态下,Mutex 示例处于 Unlocked 状态(state:0,sema:0),上述案例中,go 2 在复制了初始状态的 Mutex 实例,副本的 state 和 sema 均为 0,则与 go 2新定义的 Mutex 无异,则go 2可以继续正常运行。

后续主程序调用了 Lock 方法,Mutex 实例变为 Locked 状态,而此后 go 1 创建是恰恰复制了处于 Locked 状态的实例,那副本实例也是 Locked 状态的,所以 go 1 进去了阻塞状态(也是死锁状态,因为没有任何机会调用 Unlock 了)。

四、小结

通过本文案例可以直观的看到,sync包中的实例在首次实例化后被复制的副本一旦被使用了将导致不可预期的结果。所以在使用 sync包 的时候,推荐通过 闭包 或者 传递类型实例 的地址或指针的方式进行,这是使用 sync包 需要注意的地方。


现阶段还是对 Go 语言的学习阶段,想必有一些地方考虑的不全面,本文示例全部是亲自手敲代码并且执行通过。
如有问题,还请指教。
评论去告诉我哦!!!一起学习一起进步!!!

这篇关于GO学习之 同步操作sync包的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/347706

相关文章

使用Go实现文件复制的完整流程

《使用Go实现文件复制的完整流程》本案例将实现一个实用的文件操作工具:将一个文件的内容完整复制到另一个文件中,这是文件处理中的常见任务,比如配置文件备份、日志迁移、用户上传文件转存等,文中通过代码示例... 目录案例说明涉及China编程知识点示例代码代码解析示例运行练习扩展小结案例说明我们将通过标准库 os

深入理解Go语言中二维切片的使用

《深入理解Go语言中二维切片的使用》本文深入讲解了Go语言中二维切片的概念与应用,用于表示矩阵、表格等二维数据结构,文中通过示例代码介绍的非常详细,需要的朋友们下面随着小编来一起学习学习吧... 目录引言二维切片的基本概念定义创建二维切片二维切片的操作访问元素修改元素遍历二维切片二维切片的动态调整追加行动态

go中的时间处理过程

《go中的时间处理过程》:本文主要介绍go中的时间处理过程,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1 获取当前时间2 获取当前时间戳3 获取当前时间的字符串格式4 相互转化4.1 时间戳转时间字符串 (int64 > string)4.2 时间字符串转时间

Go语言中make和new的区别及说明

《Go语言中make和new的区别及说明》:本文主要介绍Go语言中make和new的区别及说明,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录1 概述2 new 函数2.1 功能2.2 语法2.3 初始化案例3 make 函数3.1 功能3.2 语法3.3 初始化

Go语言中nil判断的注意事项(最新推荐)

《Go语言中nil判断的注意事项(最新推荐)》本文给大家介绍Go语言中nil判断的注意事项,本文给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录1.接口变量的特殊行为2.nil的合法类型3.nil值的实用行为4.自定义类型与nil5.反射判断nil6.函数返回的

Go语言数据库编程GORM 的基本使用详解

《Go语言数据库编程GORM的基本使用详解》GORM是Go语言流行的ORM框架,封装database/sql,支持自动迁移、关联、事务等,提供CRUD、条件查询、钩子函数、日志等功能,简化数据库操作... 目录一、安装与初始化1. 安装 GORM 及数据库驱动2. 建立数据库连接二、定义模型结构体三、自动迁

Go语言代码格式化的技巧分享

《Go语言代码格式化的技巧分享》在Go语言的开发过程中,代码格式化是一个看似细微却至关重要的环节,良好的代码格式化不仅能提升代码的可读性,还能促进团队协作,减少因代码风格差异引发的问题,Go在代码格式... 目录一、Go 语言代码格式化的重要性二、Go 语言代码格式化工具:gofmt 与 go fmt(一)

Go学习记录之runtime包深入解析

《Go学习记录之runtime包深入解析》Go语言runtime包管理运行时环境,涵盖goroutine调度、内存分配、垃圾回收、类型信息等核心功能,:本文主要介绍Go学习记录之runtime包的... 目录前言:一、runtime包内容学习1、作用:① Goroutine和并发控制:② 垃圾回收:③ 栈和

Go语言中泄漏缓冲区的问题解决

《Go语言中泄漏缓冲区的问题解决》缓冲区是一种常见的数据结构,常被用于在不同的并发单元之间传递数据,然而,若缓冲区使用不当,就可能引发泄漏缓冲区问题,本文就来介绍一下问题的解决,感兴趣的可以了解一下... 目录引言泄漏缓冲区的基本概念代码示例:泄漏缓冲区的产生项目场景:Web 服务器中的请求缓冲场景描述代码

Go语言如何判断两张图片的相似度

《Go语言如何判断两张图片的相似度》这篇文章主要为大家详细介绍了Go语言如何中实现判断两张图片的相似度的两种方法,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 在介绍技术细节前,我们先来看看图片对比在哪些场景下可以用得到:图片去重:自动删除重复图片,为存储空间"瘦身"。想象你是一个