Go语言线程安全之互斥锁与读写锁
前言:
单个线程时数据操作的只有一个线程,数据的修改也只有一个线程参与,数据相对来说是安全的,多线程时对数据操作的不止一个线程,所以同时对数据进行修改的时候难免紊乱
一、互斥锁是什么?
1.概念
互斥锁是为了并发的安全,在多个goroutine
共同工作的时候,对于共享的数据十分不安全写入时容易因为竞争造成数据不必要的丢失。互斥锁一般加在共享数据修改的地方。
2.未加锁
- 线程不安全,操作的全局变量会计算异常
package main import ( "fmt" "sync" ) var x int = 0 var wg sync.WaitGroup func add() { defer wg.Done() for i := 0; i < 5000; i++ { x++ } } func main() { wg.Add(2) go add() go add() wg.Wait() fmt.Println(x) } /* 打印结果:(每次打印不一样,正常的结果应该是10000) 6051 5059 5748 10000 */
3.加锁之后
- 线程安全,全局变量计算无异常
package main import ( "fmt" "sync" ) var x int = 0 var wg sync.WaitGroup // 创建一个锁对象 var lock sync.Mutex func add() { defer wg.Done() for i := 0; i < 5000; i++ { //加锁 lock.Lock() x++ //解锁 lock.Unlock() } } func main() { wg.Add(2) //开启两个线程 go add() go add() wg.Wait() fmt.Println(x) } /* 打印结果: 全为10000 */
二、读写锁【效率革命】
1.为什么读写锁效率高
使用锁的时候,安全与效率往往需要互相转换,对数据进行操作的时候,只会进行数据的读与写。 而读与读之间可以同时进行,读与写之间需要保证写的时候不去读。此时为了提高效率就发明读写锁,在读写锁机制下,安全没有丝毫降低,但效率进行了成倍的提升提升的效率在读与写操作次数差异越大时越明显
2.使用方法
代码如下(示例):
package main import ( "fmt" "sync" "time" ) var ( x = 0 rwlock sync.RWMutex wg sync.WaitGroup ) func write() { defer wg.Done() rwlock.Lock() x++ rwlock.Unlock() } func read() { wg.Done() //开启读锁 rwlock.RLock() fmt.Println(x) //释放读锁 rwlock.RUnlock() } func main() { start := time.Now() for i := 0; i < 100; i++ { wg.Add(1) go write() } // time.Sleep(time.Second) for i := 0; i < 10000; i++ { wg.Add(1) go read() } wg.Wait() fmt.Println(time.Now().Sub(start)) }
三、sync.once
1.sync.once产生背景
在多个goroutine
中往往会由于线程不同步造成数据读写的冲突,特别是在进行文件打开对象创建的时候,可能会造成向关闭的文件写内容,使用未初始化的对象,或者对一个对象进行多次初始化。
2.sync.once机制概述
sync.once
保证函数内的代码只执行一次, 实现的机制是在once内部有一个标志位,在执行代码的时候执行一次之后标志位将置为1后续判断标志位,如果标志位被改为1则无法再进行操纵
3.sync.once注意点
sync.Once.Do()
传进去的函数参数无参无返,一个once对象只能执行一次Do方法,向Do方法内传多个不同的函数时只能执行第一个传进去的,传进去Do方法的函数无参无返,可以用函数闭包把需要的变量传进去
4.使用方法
- 一般结合并发使用,旨在对通道或文件只进行一次关闭
func f2(a <-chan int, b chan<- int) { for { x, ok := <-a if !ok { break } fmt.Println(x) b <- x * 10 } // 确保b通道只关闭一次 once.Do(func() { close(b) }) }
四、atomic原子包操作
原子包将指定的数据进行安全的加减交换操作; 网上还有一大堆关于原子包的api感兴趣的小伙伴可以自行百度,这里就不细细阐述了
package main import ( "fmt" "sync" "sync/atomic" ) var x int64 = 0 var wg sync.WaitGroup /* 原子操作是将数据进行打包枷锁,直接通过指定的函数进行相应的操作 可以使用load读取、store写入、add修改、swap交换。 // 类似于读取一个变量、对一个变量进行赋值 */ func addone() { // 没有加锁进行并发的话,会产生数据丢失的情况 defer wg.Done() // x++ // 不用加锁也可以使用的行云流水 // 第一个参数是进行操作的数据,第二个是增加的步长 atomic.AddInt64(&x, 1) } func csf() { // 进行比较相等则将新值替换旧值 ok := atomic.CompareAndSwapInt64(&x, 100, 200) fmt.Println(ok, x) } func main() { for i := 0; i < 50000; i++ { wg.Add(1) go addone() } wg.Wait() fmt.Println(x) x = 100 csf() fmt.Println(123) }
总结:
读写锁区分读者和写者,而互斥锁不区分 互斥锁同一时间只允许一个线程访问该对象,无论读写;读写锁同一时间内只允许一个写者, 但是允许多个读者同时读对象。 联系:读写锁在获取写锁的时候机制类似于互斥锁。
到此这篇关于Go语言线程安全之互斥锁与读写锁的文章就介绍到这了,更多相关Go语言互斥锁与读写锁内容请搜索猪先飞以前的文章或继续浏览下面的相关文章希望大家以后多多支持猪先飞!
原文出处:https://blog.csdn.net/apple_51931783/article/details/1225532
相关文章
C# WinForm多线程解决界面卡死问题的完美解决方案,使用BeginInvoke
问题描述:当我们的界面需要在程序运行中不断更新数据时,当一个textbox的数据需要变化时,为了让程序执行中不出现界面卡死的现像,最好的方法就是多线程来解决一个主线程来创建界...2020-06-24- 在程序员中,尤其是go新手,经常听到的一个讨论话题是:如何处理错误,这篇文章主要给大家介绍了关于Go应用中优雅处理Error的一些相关技巧,需要的朋友可以参考下...2021-09-08
- 这篇文章主要介绍了C#停止线程的方法,实例分析了C#正确停止线程的实现技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 今天小编就为大家分享一篇关于C#开启线程的四种方式示例详解,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧...2020-06-25
- 作为前端,一直以来都知道HTTP劫持与XSS跨站脚本、CSRF跨站请求伪造。防御这些劫持最好的方法是从后端入手,前端能做的太少。而且由于源码的暴露,攻击者很容易绕过防御手段。但这不代表我们去了解这块的相关知识是没意义的,本文的许多方法,用在其他方面也是大有作用。...2021-05-24
- 这篇文章主要介绍了C# 线程相关知识,文中讲解非常细致,代码帮助大家更好的理解和学习,感兴趣的朋友可以了解下...2020-11-03
- 这篇文章主要介绍了c# 多线程处理多个数据的方法,帮助大家更好的理解和学习使用c#,感兴趣的朋友可以了解下...2021-03-31
- 这篇文章主要介绍了C#实现跨线程操作控件方法,主要采用异步访问方式实现,需要的朋友可以参考下...2020-06-25
Django def clean()函数对表单中的数据进行验证操作
这篇文章主要介绍了Django def clean()函数对表单中的数据进行验证操作,具有很好的参考价值,希望对大家有所帮助。一起跟随小编过来看看吧...2020-07-09- 这篇文章主要介绍了C#基于委托实现多线程之间操作的方法,实例分析了C#的委托机制与多线程交互操作的相关技巧,具有一定参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了C#多线程中的异常处理操作,涉及C#多线程及异常的捕获、处理等相关操作技巧,需要的朋友可以参考下...2020-06-25
- 这篇文章主要介绍了c# 线程同步的相关资料,帮助大家更好的理解和学习c#,感兴趣的朋友可以了解下...2020-08-29
- 这篇文章主要介绍了C#中异步和多线程的相关资料,帮助大家更好的理解和学习c#,感兴趣的朋友可以了解下...2021-01-16
- 多线程和异步操作两者都可以达到避免调用线程阻塞的目的,从而提高软件的可响应性。甚至有些时候我们就认为多线程和异步操作是等同的概念。但是,多线程和异步操作还是有一些区别的。而这些区别造成了使用多线程和异步操作的时机的区别...2020-06-25
- 普通关闭 我的mysql是自己下载的tar包,自己设定安装目录来安装的。停止mysql服务,说来简单,但不知道的话,还真是挠头。在这和mysql入门的同学们共享:)正确方法是,进入mysql的bin目录下,然后执行./mysqladmin -uroot -p shut...2015-11-24
- 这篇文章主要介绍了解决线程并发redisson使用遇到的坑,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教...2021-06-18
- 这篇文章主要为大家详细介绍了C#多线程之Thread类,具有一定的参考价值,感兴趣的小伙伴们可以参考一下...2020-06-25
- 在Java中,我们可以利用多线程来最大化地压榨CPU多核计算的能力,下面这篇文章主要给大家介绍了关于java中多线程与线程池基本使用的相关资料,需要的朋友可以参考下...2021-09-13
- 这篇文章主要介绍了C#向线程中传递多个参数的解决方法(两种)的相关资料,非常不错,具有参考借鉴价值,需要的朋友可以参考下...2020-06-25
- 第一种解决方案的原理是:将线程执行的方法和参数都封装到一个类里面。通过实例化该类,方法就可以调用属性来实现间接的类型安全地传递多个参数...2020-06-25