Go语言开发保证并发安全实例详解

 更新时间:2022年09月02日 09:09:52   作者:Sundar84034  
这篇文章主要为大家介绍了Go语言开发保证并发安全实例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪

什么是并发安全?

高并发场景下,进程、线程(协程)可能会发生资源竞争,导致数据脏读、脏写、死锁等问题,为了避免此类问题的发生,就有了并发安全。

这里举一个简单的例子:

 var data int 
 go func() {
   data++ 
 }() 
 if data == 0 { 
   fmt.Printf("the value is %v.\n", data) 
 }

在这段代码中

第2行go关键字开启了一个新的协程,来执行data++操作

第5行,对data变量进行了读取判断的操作

以上两部是由2个不同线程/协程运行,且没有任何措施保证执行顺序,所以执行结果是不确定的。

  • 没有输出。(第3行是在第5行之前执行的)
  • 输出 the value is 0。(第5行和第6行在第3行之前执行)
  • 输出 the value is 1。(第5行在第3行之前执行,但第3行在第6行之前执行)

Go如何保证并发安全

目前了解到的,大概有这3种,Mutex、Channel、Atomic

Mutex

加锁应该是最常见的并发控制方法,一般分成两种,乐观锁和悲观锁

锁是由操作系统的调度器来实现的,锁通常用来保护一段逻辑,

悲观锁

悲观锁是一种悲观思想,它总认为最坏的情况可能会出现。不管意料之外的结果是否会发生,只要存在发生的可能,就在操作这个资源之前先上锁。例如互斥锁读写锁都是悲观锁。

在go中,除了automic,其它都是悲观锁

悲观锁应该都是由操作系统的调度器来实现的,通常用来保护一段逻辑,主要是通过阻塞其它线程,保证当前时刻只有一个线程在对资源进行操作,因此性能相对较差,浪费了计算机多核的优势。

乐观锁

乐观锁的思想与悲观锁的思想相反,它总认为资源和数据不会被别人所修改,所以读取不会上锁,但是乐观锁在进行写入操作的时候会判断当前数据是否被修改过

乐观锁的实现方案主要包含CAS版本号机制

乐观锁适用于多读的场景,可以提高吞吐量。

版本号机制

通过在数据表中,增加一个版本号字段,当数据发生更新时,版本号值发生改变。 例如一个线程A想要更新变量s的值,在读取s的值的同时读取版本号,在提交更新时,用之前读到的版本号值与当前的版本号值进行比对,当且仅当版本号值一致时,才会触发更新,否则不断进行重试,直到更新成功。

CAS

CAS全名为Compare And Swap,即比较与转换,是一种有名的无锁算法。在不使用锁的情况下,实现多线程之间的变量同步,也就是在没有线程被阻塞的情况下实现变量的同步,所以也叫非阻塞同步,

互斥锁

GO使用Sync包的Mutex类型来实现互斥锁,它能保证同时只有一个goroutine可以访问资源。

func sample() {
	var l sync.Mutex
	l.Lock()
        defer l.Unlock()
	// so something
}

读写互斥锁

GO使用Sync包的RWMutex类型来实现互斥锁。当我们去并发的读取一个资源,只要数据没有发生写入,是没必要加锁的。因此读多写少的情况下,使用读写互斥锁是更好的选择,性能更好。

读写锁分为两种:读锁和写锁。

当一个goroutine获取读锁之后,其他的goroutine如果是获取读锁可以顺利获得,如果是获取写锁就会等待;

当一个goroutine获取写锁之后,其他的goroutine无论是获取读锁还是写锁都会等待。

package main
import (
	"fmt"
	"sync"
	"time"
)
var (
	wg     sync.WaitGroup
	rwlock sync.RWMutex
)
func write() {
	rwlock.Lock() // 加写锁
	time.Sleep(10 * time.Millisecond)
	rwlock.Unlock() // 解写锁
	wg.Done()
}
func read() {
	rwlock.RLock() // 加读锁
	time.Sleep(time.Millisecond)
	rwlock.RUnlock() // 解读锁
	wg.Done()
}
func main() {
	start := time.Now()
	//读多
	for i := 0; i < 1000; i++ {
		wg.Add(1)
		go read()
	}
	//写少
	for i := 0; i < 10; i++ {
		wg.Add(1)
		go write()
	}
	wg.Wait()
	end := time.Now()
	fmt.Println(end.Sub(start))
}

以上就是Go语言开发保证并发安全实例详解的详细内容,更多关于Go保证并发安全的资料请关注脚本之家其它相关文章!

相关文章

  • golang的httpserver优雅重启方法详解

    golang的httpserver优雅重启方法详解

    这篇文章主要给大家介绍了关于golang的httpserver优雅重启的相关资料,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧。
    2018-03-03
  • Go语言的GOPATH与工作目录详解

    Go语言的GOPATH与工作目录详解

    这篇文章主要介绍了Go语言的GOPATH与工作目录详解,本文详细讲解了GOPATH设置、应用目录结构、编译应用等内容,需要的朋友可以参考下
    2014-10-10
  • 使用go语言解析xml的实现方法(必看篇)

    使用go语言解析xml的实现方法(必看篇)

    下面小编就为大家带来一篇使用go语言解析xml的实现方法(必看篇)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-06-06
  • Go结合JavaScript实现抓取网页中的图像链接

    Go结合JavaScript实现抓取网页中的图像链接

    这篇文章主要为大家详细介绍了Go语言如何结合JavaScript实现抓取网页中的图像链接,文中的示例代码讲解详细,有需要的小伙伴可以跟随小编一起学习一下
    2023-11-11
  • golang struct json tag的使用以及深入讲解

    golang struct json tag的使用以及深入讲解

    这篇文章主要给大家介绍了关于golang struct json tag的使用以及深入讲解,文中通过实例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2022-02-02
  • Go语言中实现enum枚举的方法详解

    Go语言中实现enum枚举的方法详解

    枚举,即 enum,可用于表示一组范围固定的值,它能助我们写出清晰、安全的代码,那么你是否了解过 Go 中的枚举呢?下面就跟随小编一起来学习一下Go语言中实现enum枚举的常用方法吧
    2024-02-02
  • Go语言针对Map的11问你知道几个?

    Go语言针对Map的11问你知道几个?

    Go Map 的 11 连问,你顶得了嘛?这篇文章小编为大家准备了 Go 语言 Map 的 11 连问,相信大家看完肯定会有帮助的,感兴趣的小伙伴可以收藏一波
    2023-05-05
  • Go语言编程通过dwarf获取内联函数

    Go语言编程通过dwarf获取内联函数

    这篇文章主要为大家介绍了Go语言编程通过dwarf获取内联函数详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
    2022-11-11
  • Golang字符串拼接的性能以及原理详解

    Golang字符串拼接的性能以及原理详解

    最近在做性能优化,有个函数里面的耗时特别长,看里面的操作大多是一些字符串拼接的操作,而字符串拼接在golang里面其实有很多种实现,下面这篇文章主要给大家介绍了关于Golang字符串拼接的性能以及原理的相关资料,需要的朋友可以参考下
    2023-06-06
  • Go语言实现定时器的原理及使用详解

    Go语言实现定时器的原理及使用详解

    这篇文章主要为大家详细介绍了Go语言实现定时器的两种方法:一次性定时器(Timer)和周期性定时器(Ticker),感兴趣的小伙伴可以跟随小编一起学习一下
    2022-12-12

最新评论