- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章Go语言线程安全之互斥锁与读写锁由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
前言:
单个线程时数据操作的只有一个线程,数据的修改也只有一个线程参与,数据相对来说是安全的,多线程时对数据操作的不止一个线程,所以同时对数据进行修改的时候难免紊乱 。
互斥锁是为了并发的安全,在多个goroutine共同工作的时候,对于共享的数据十分不安全写入时容易因为竞争造成数据不必要的丢失。互斥锁一般加在共享数据修改的地方.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
|
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
*/
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
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
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
|
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))
}
|
在多个goroutine中往往会由于线程不同步造成数据读写的冲突,特别是在进行文件打开对象创建的时候,可能会造成向关闭的文件写内容,使用未初始化的对象,或者对一个对象进行多次初始化.
sync.once保证函数内的代码只执行一次, 实现的机制是在once内部有一个标志位,在执行代码的时候执行一次之后标志位将置为1后续判断标志位,如果标志位被改为1则无法再进行操纵 。
sync.Once.Do()传进去的函数参数无参无返,一个once对象只能执行一次Do方法,向Do方法内传多个不同的函数时只能执行第一个传进去的,传进去Do方法的函数无参无返,可以用函数闭包把需要的变量传进去 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
|
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)
})
}
|
原子包将指定的数据进行安全的加减交换操作; 网上还有一大堆关于原子包的api感兴趣的小伙伴可以自行百度,这里就不细细阐述了 。
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
|
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/122553203 。
最后此篇关于Go语言线程安全之互斥锁与读写锁的文章就讲到这里了,如果你想了解更多关于Go语言线程安全之互斥锁与读写锁的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
我只是有一个关于 Java 并发编程的简单问题。例如,我有一个 NxN 矩阵,矩阵的每一行都有一个对应的线程,如果每一行中的线程之间没有交互,如果多个线程同时访问和修改矩阵的单独行是否安全(或正确)?
jwplayer("myElement_0").onPlay(function(){ pausePlayers(1); alert('0 has started'); }); jwplayer("my
我在想。当我使用一个std::mutex _lock 并想依赖守卫来释放它时,我可以这样使用吗? class MyClass{ private: mutable std::mutex _loc
这种互斥模式是否像我认为的那样安全?如果是这样,你怎么调用它? lock (_lock) { if (_flag) return; else _flag = true; } try {
我有一个静态库 来访问数据库。它有一个函数 readMaximum()。 readMaximum() 从数据库中读取最大值。此函数是线程安全的(使用互斥量)。 但问题是: 有两个进程A.exe和B.e
我正在为互斥锁的逻辑而苦苦挣扎;我在这里检查 key 是否被拿走,如果没有,我们拿走它,完成后释放它;但是你能帮我看看我怎样才能有一个循环来检查 key 直到它可用吗? rdb.setnx(lockk
我正在使用 clp(fd) 编写 Prolog 程序并且我很难实现我想要的约束之一。 输出是一个整数列表(长度取决于程序另一部分的输入),其中有某些相互排斥的预定义数字对,每对中的一个数字必须在输出中
我正在尝试使用 mesos/marathon 实现一个 lizardfs 集群。为此,我创建了一些 docker 镜像。 我需要获取某种类型的 docker 容器(lizardfs-master),而
假设我有一个包含以下列的 MySQL 表: |variables|1. | 'a' |2. | 'a b' |3. | 'a b c' |4. | ... | How can
我在一个表单上有 7 个单选按钮 其中3个属于一个组,4个属于另一个组 我希望 RadioButtons 在组内互斥。 这可以通过将它们放在两个 GroupBox 中来实现, 有没有什么办法可以不把它
我正在尝试使文本输入和复选框相互排斥。 默认情况下,文本框应包含“0”,复选框应为 false。如果用户选中该复选框,则该文本框应被清空。如果用户在文本框中输入值,则应取消选中该复选框。任何时候都不应
我已经在代码的注释中写下了我的问题。 我正在尝试使用 pthreads 使我的代码并行。首先,我想通过多个线程并行地在内存中写入大量数据。写入数据后,我想通过相同的线程执行此数据。执行数据后,我想读取
这个问题在这里已经有了答案: 关闭 13 年前。 Possible Duplicate: Monitor vs Mutex in c# 你好, 在这个网站上,我发现来自不同人的不同答案令人困惑。仍然
我需要调用一个返回唯一 id 的函数, int getid() { static id=0; id++; return id; } 多个线程需要调用这个函数,我的问题是我不确定我需要在哪里锁定互斥量,
请引用来自 WWDC 的视频 https://developer.apple.com/videos/play/wwdc2015/226/演讲者展示了我们可以在两个相同类型的 NSopeation 实例
概述: 我有一个使用 CoreData 的 iOS 应用程序> 有一个名为Animal的实体 它有一组记录Lion、Tiger和Elephant 我想将只有一个记录标记为收藏。 具有相同方法的相似实体
这个问题在这里已经有了答案: 关闭 12 年前。 Possible Duplicate: DLL thread safety 你好 我正在 MS VS C++ express 中编写一个 DLL 文
我的应用程序被迫使用第 3 方模块,如果在同一台机器上同时启动两个实例,该模块将使 Windows 蓝屏。为了解决这个问题,我的 C# 应用程序有一个互斥量: static Mutex mutex =
我是 Go 的新手,我想实现一个自定义的互斥机制,每个应用程序用户一次可以执行一个 goroutine。为简化起见,将 U1 和 U2 视为应用程序用户以及 F1(userId)、F2(userId)
我需要将单选和多选的功能组合到一个控件中。具体来说,我有多种选择。第一个与其他的互斥。所以,如果我选择第一个,就需要取消选中所有其他的。如果选择了其中一个,则必须取消选中第一个(如果已选择)。其他选项
我是一名优秀的程序员,十分优秀!