golang并发安全及读写互斥锁的示例分析

更新时间：2022年04月14日 13:29:09 作者：Jeff的技术栈

这篇文章主要为大家介绍了golang并发安全及读写互斥锁的示例分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步早日升职加薪

并发安全和锁

有时候在Go代码中可能会存在多个goroutine同时操作一个资源（临界区），这种情况会发生竞态问题（数据竞态）。类比现实生活中的例子有十字路口被各个方向的的汽车竞争；还有火车上的卫生间被车厢里的人竞争。

举个例子：

var x int64
var wg sync.WaitGroup
func add() {
    for i := 0; i < 5000; i++ {
        x = x + 1
    }
    wg.Done()
}
func main() {
    wg.Add(2)
    go add()
    go add()
    wg.Wait()
    fmt.Println(x)
}

上面的代码中我们开启了两个goroutine去累加变量x的值，这两个goroutine在访问和修改x变量的时候就会存在数据竞争，导致最后的结果与期待的不符。

互斥锁

import (
	"fmt"
	"sync"
)
var lock sync.Mutex
lock.Lock() // 加锁
lock.Unlock() // 解锁

互斥锁是一种常用的控制共享资源访问的方法，它能够保证同时只有一个goroutine可以访问共享资源。Go语言中使用sync包的Mutex类型来实现互斥锁。使用互斥锁来修复上面代码的问题：

var x int64
var wg sync.WaitGroup
var lock sync.Mutex
func add() {
    for i := 0; i < 5000; i++ {
        lock.Lock() // 加锁
        x = x + 1
        lock.Unlock() // 解锁
    }
    wg.Done()
}
func main() {
    wg.Add(2)
    go add()
    go add()
    wg.Wait()
    fmt.Println(x)
}

使用互斥锁能够保证同一时间有且只有一个goroutine进入临界区，其他的goroutine则在等待锁；当互斥锁释放后，等待的goroutine才可以获取锁进入临界区，多个goroutine同时等待一个锁时，唤醒的策略是随机的。

读写互斥锁

import (
	"fmt"
	"sync"
)
var rwlock sync.RWMutex
rwlock.Lock()   // 加写锁
rwlock.Unlock() // 解写锁

互斥锁是完全互斥的，但是有很多实际的场景下是读多写少的，当我们并发的去读取一个资源不涉及资源修改的时候是没有必要加锁的，这种场景下使用读写锁是更好的一种选择。读写锁在Go语言中使用sync包中的RWMutex类型。

读写锁分为两种：读锁和写锁。当一个goroutine获取读锁之后，其他的goroutine如果是获取读锁会继续获得锁，如果是获取写锁就会等待；当一个goroutine获取写锁之后，其他的goroutine无论是获取读锁还是写锁都会等待。

读写锁示例：

var (
    x      int64
    wg     sync.WaitGroup
    lock   sync.Mutex
    rwlock sync.RWMutex
)
func write() {
    // lock.Lock()   // 加互斥锁
    rwlock.Lock() // 加写锁
    x = x + 1
    time.Sleep(10 * time.Millisecond) // 假设读操作耗时10毫秒
    rwlock.Unlock()                   // 解写锁
    // lock.Unlock()                     // 解互斥锁
    wg.Done()
}
func read() {
    // lock.Lock()                  // 加互斥锁
    rwlock.RLock()               // 加读锁
    time.Sleep(time.Millisecond) // 假设读操作耗时1毫秒
    rwlock.RUnlock()             // 解读锁
    // lock.Unlock()                // 解互斥锁
    wg.Done()
}
func main() {
    start := time.Now()
    for i := 0; i < 10; i++ {
        wg.Add(1)
        go write()
    }

    for i := 0; i < 1000; i++ {
        wg.Add(1)
        go read()
    }
    wg.Wait()
    end := time.Now()
    fmt.Println(end.Sub(start))
}

需要注意的是读写锁非常适合读多写少的场景，如果读和写的操作差别不大，读写锁的优势就发挥不出来。

以上就是golang并发安全及读写互斥锁的示例分析的详细内容，更多关于golang并发安全及读写互斥锁的资料请关注脚本之家其它相关文章！

您可能感兴趣的文章:

Golang爬虫框架colly使用浅析
这篇文章主要介绍了Golang爬虫框架colly的使用，colly是Go实现的比较有名的一款爬虫框架，而且Go在高并发和分布式场景的优势也正是爬虫技术所需要的，感兴趣想要详细了解可以参考下文
2023-05-05
Golang使用协程实现批量获取数据
服务端经常需要返回一个列表，里面包含很多用户数据，常规做法当然是遍历然后读缓存。使用Go语言后，可以并发获取，极大提升效率，本文就来聊聊具体的实现方法，希望对大家有所帮助
2023-02-02
Golang中如何使用lua进行扩展详解
这篇文章主要给大家介绍了关于Golang中如何使用lua进行扩展的相关资料，这是最近在工作中遇到的一个问题，觉着有必要分享出来给大家学习，文中给出了详细的示例，需要的朋友可以参考借鉴，下面来一起看看吧。
2017-10-10
Go语言快速入门图文教程
Go是 Goolge 开发的一种静态型、编译型、并发型，并具有垃圾回收功能的语言，Go 语言上手非常容易，它的风格类似于 C 语言，Go 语言号称是互联网时代的 C 语言，那么它到底有多火呢，一起看看吧
2021-05-05
一文带你掌握Go语言中的文件读取操作
这篇文章主要和大家分享一下Go语言中的文件读取操作，文中的示例代码讲解详细，对我们学习Go语言有一定的帮助，需要的小伙伴可以参考一下
2022-12-12
使用go求幂的几种方法小结
这篇文章主要介绍了使用go求幂的几种方法小结，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2020-12-12
go语言int64整型转字符串的实现
本文主要介绍了go语言int64整型转字符串的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2023-03-03
Go中Channel发送和接收操作指南
在golang中channel属于较为核心的一个功能,尤其在go协程中,channel功能尤为重要,下面这篇文章主要给大家介绍了关于Go中Channel发送和接收操作的相关资料,需要的朋友可以参考下
2021-08-08
Golang使用Channel组建高并发HTTP服务器
Golang 作为一门高效的语言，在网络编程方面表现也非常出色，这篇文章主要介绍了如何使用 Golang 和 Channel 组建高并发 HTTP 服务器，感兴趣的可以了解一下
2023-06-06
解决电脑用GoLand太卡将VsCode定制成Go IDE步骤过程
这篇文章主要为大家介绍了解决电脑用GoLand太卡,将VsCode定制成Go IDE步骤过程详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-11-11