golang rwmutex 详细介绍
本篇文章介绍如何在 go 语言中使用 rwmutex。
go 语言 rwmutex
mutex 是 mutual exclusion 的缩写,用于随时跟踪哪个线程访问了某个变量。 互斥量是 golang 的 sync 包中提供的数据结构。
在使用 go 代码执行并发时使用互斥锁。 下面是一个在 golang 中使用互斥量的简单示例。
package main
import (
"fmt"
"sync"
"time"
)
func evennumber(num int) bool {
return num%2 == 0
}
func main() {
num := 2
var demomutex sync.mutex
go func() {
demomutex.lock()
defer demomutex.unlock()
evennum := evennumber(num)
time.sleep(5 * time.millisecond)
if evennum {
fmt.println("the number", num, " is even")
return
}
fmt.println("the number", num, "is odd")
}()
go func() {
demomutex.lock()
num
demomutex.unlock()
}()
time.sleep(time.second)
}
上面的代码检查数字是偶数还是奇数。 这里并发的 goroutines 可能会破坏数据,所以我们使用互斥体来锁定和解锁数据以防止数据被破坏。
查看输出:
the number 2 is even
mutex和rwmutex的区别在于mutex是一个简单的mutex,而rwmutex是一个读写互斥锁。 使用 rwmutex,锁由任意数量的读取器或一个写入器持有。
当 rwmutex 的值为零时,它是一个未锁定的互斥体。 让我们用 rwmutex 互斥量尝试相同的例子。
package main
import (
"fmt"
"sync"
"time"
)
func evennumber(num int) bool {
return num%2 == 0
}
func main() {
num := 2
var demorwm sync.rwmutex
// both goroutines call demorwm.lock() before accessing `num` and then call the demorwm.unlock after they are done
go func() {
demorwm.rlock()
defer demorwm.runlock()
evennum := evennumber(num)
time.sleep(5 * time.millisecond)
if evennum {
fmt.println("the number", num, " is even")
return
}
fmt.println("the number", num, "is odd")
}()
go func() {
demorwm.lock()
num
demorwm.unlock()
}()
time.sleep(time.second)
}
正如我们在这里看到的,两个 goroutines 在访问 num 之前调用 demorwm.lock()
,然后在完成后调用 demorwm.unlock 。 该代码使用 rwmutex。
查看输出:
the number 2 is even
让我们尝试另一个 rwmutex 示例,其中 rwmutex 允许所有读取器同时访问数据,而写入器将锁定其他读取器。
看例子:
package main
import (
"fmt"
"sync"
)
func main() {
demomap := map[int]int{}
demorwm := &sync.rwmutex{}
go loopwrite(demomap, demorwm)
go loopread(demomap, demorwm)
go loopread(demomap, demorwm)
go loopread(demomap, demorwm)
go loopread(demomap, demorwm)
go loopread(demomap, demorwm)
go loopread(demomap, demorwm)
go loopread(demomap, demorwm)
go loopread(demomap, demorwm)
// stop the program from exiting must be killed
stopblock := make(chan struct{})
<-stopblock
}
func loopread(demomap map[int]int, demorwm *sync.rwmutex) {
for {
demorwm.rlock()
for k, v := range demomap {
fmt.println(k, "-", v)
}
demorwm.runlock()
}
}
func loopwrite(demomap map[int]int, demorwm *sync.rwmutex) {
for {
for i := 0; i < 100; i {
demorwm.lock()
demomap[i] = i
demorwm.unlock()
}
}
}
如我们所见,rwmutex 允许我们根据需要多次使用读取; 此代码的输出将如下所示:
timeout running program
0 - 0
0 - 0
0 - 0
0 - 0
0 - 0
0 - 0
0 - 0
0 - 0
1 - 1
转载请发邮件至 1244347461@qq.com 进行申请,经作者同意之后,转载请以链接形式注明出处
本文地址:
相关文章
发布时间:2023/04/27 浏览次数:101 分类:
-
本篇文章介绍了在 golang 的 html 模板中使用 if-else 和 switch 循环。因此,只要输出是 html,就应该始终使用 html 模板包而不是文本模板。
发布时间:2023/04/27 浏览次数:184 分类:
-
本篇文章介绍 nil 在 golang 中的含义,nil 是 go 编程语言中的零值,是众所周知且重要的预定义标识符。
golang 中的 lambda 表达式
发布时间:2023/04/27 浏览次数:691 分类:
-
本篇文章介绍如何在 golang 中创建 lambda 表达式。lambda 表达式似乎不存在于 golang 中。 函数文字、lambda 函数或闭包是匿名函数的另一个名称。
发布时间:2023/04/27 浏览次数:136 分类:
-
当我们尝试生成对象的副本时,深层副本会准确复制原始对象的所有字段。 此外,如果它有任何对象作为字段,也会制作这些对象的副本。本篇文章介绍如何在 golang 中进行深度复制。
发布时间:2023/04/27 浏览次数:104 分类:
-
像错误一样,panic 发生在运行时。 换句话说,当您的 go 程序中出现意外情况导致执行终止时,就会发生 panics。让我们看一些例子来捕捉 golang 中的panics。
go 中的日志级别
发布时间:2023/04/27 浏览次数:585 分类:
-
本篇文章介绍如何在 golang 中创建和使用日志级别。go 中的日志级别。golang提供了一个日志包,名为log,是一个简单的日志包。 这个包不提供分级日志; 如果我们想要分级日志记录,我们必须
在 go 中使用断言
发布时间:2023/04/27 浏览次数:585 分类:
-
本篇文章介绍了 assert 在 golang 中的使用。在 go 语言中使用断言:golang 不提供对断言的任何内置支持,但我们可以使用来自 testify api 的广泛使用的第三方包断言。
go 中的随机数生成
发布时间:2023/04/27 浏览次数:206 分类:
-
本篇文章介绍如何在 go 语言中使用随机数生成功能。go 中的随机数生成 go 语言为随机数生成功能提供内置支持。 内置包 math 有方法 rand(),用于随机数生成。