Go 分布式学习利器（18）-- Go并发编程之lock+WaitGroup实现线程安全

Go语言中通过Groutine 启动一个Go协程，不同协程之间是并发执行的，就像C++/Java中线程之间线程安全是一个常见的问题。
如下Go 语言代码:

func TestConcurrent(t *testing.T) {var counter int = 0for i := 0;i < 5000; i ++{go func() { // 启动groutine 进行变量的自增counter ++}()}time.Sleep(time.Second * 1)t.Logf("Counter = %d", counter)
}

最后的结果输出如下:

=== RUN   TestConcurrentconcurrent_test.go:18: Counter = 4663
--- PASS: TestConcurrent (1.00s)

希望变量Counter的结果是5000，最终因为协程之间并发访问共享内存的原因导致部分协程执行的结果没有得到变更，从而数据不符合预期。

Go中提供了Mutex和RWMutex ，来实现锁功能。前者就是正常的Lock, Unlock；后者提供了读写锁，在协程读写分离中提供了读读互不影响，读写互斥。

如下测试代码：

func TestMutex(t *testing.T) {var counter int = 0// var mu sync.Mutex // mutex lockvar mu sync.RWMutex // rwmutex lockfor i := 0;i < 5000; i ++{go func() {// defer mutex unlock// 如果协程异常退出，能够释放锁defer func() { mu.Unlock()}()mu.Lock()counter ++}()}time.Sleep(time.Second * 1)t.Logf("Counter = %d", counter)
}

最终输出如下，通过mutex 实现了变量访问的安全:

=== RUN   TestMutexconcurrent_test.go:36: Counter = 5000
--- PASS: TestMutex (1.01s)

可以看到如上代码需要通过Sleep来让所有的协程都执行完，显然不合理。、

假如有更多的协程，这个sleep时间还需要程序员来修改，Go语言提供了WaitGroup机制，就像是C++中的条件变量，主线程可以等待在条件变量上，当线程执行完可以通过条件变量唤醒主线程继续执行。
var wg sync.WaitGroup 声明一个WaitGroup变量
通过wg.Add(1) 和 wg.Done() 来检测线程的完成情况，wg.Wait()表示主线程等待在wg变量上

func TestWaitGroup(t *testing.T) {var counter int = 0var mu sync.RWMutex // rw lock, 读写互斥var wg sync.WaitGroupfor i := 0;i < 5000; i ++{wg.Add(1) go func() {defer func() {mu.Unlock()}()mu.Lock()counter ++wg.Done() // wg.Add(-1)}()}wg.Wait()t.Logf("Counter = %d", counter)
}

输出如下，可以看到TestWaitGroup 函数的执行时间很快，不需要Sleep方式来消耗更多的时间使程序被动执行完毕。

=== RUN   TestWaitGroupconcurrent_test.go:57: Counter = 5000
--- PASS: TestWaitGroup (0.00s)

Go 分布式学习利器（18）-- Go并发编程之lock+WaitGroup实现线程安全相关推荐

java线程安全的set_Java并发编程之set集合的线程安全类你知道吗
Java并发编程之-set集合的线程安全类 Java中set集合怎么保证线程安全,这种方式你知道吗? 在Java中set集合是本篇是<凯哥(凯哥并发编程学习>系列之<并发集合系列& ...
Java并发编程之Lock
Java并发编程:Lock Java并发编程:Lock 在上一篇文章中我们讲到了如何使用关键字synchronized来实现同步访问.本文我们继续来探讨这个问题,从Java 5之后,在java.uti ...
java 时间戳_Java并发编程之CAS三CAS的缺点及解决办法
Java并发编程之CAS第三篇-CAS的缺点通过前两篇的文章介绍,我们知道了CAS是什么以及查看源码了解CAS原理.那么在多线程并发环境中,的缺点是什么呢?这篇文章我们就来讨论讨论本篇是<凯 ...
并发编程之CPU缓存架构缓存一致性协议详解(二)
并发编程之CPU缓存架构&缓存一致性协议详解 CPU高速缓存(Cache Memory) CPU高速缓存在CPU访问存储设备时,无论是存取数据抑或存取指令,都趋于聚集在一片连续的区域中,这就 ...
Java 并发编程之美：并发编程高级篇之一-chat
借用 Java 并发编程实践中的话:编写正确的程序并不容易,而编写正常的并发程序就更难了.相比于顺序执行的情况,多线程的线程安全问题是微妙而且出乎意料的,因为在没有进行适当同步的情况下多线程中各个操作 ...
Java 并发编程之美：并发编程高级篇之一
借用 Java 并发编程实践中的话:编写正确的程序并不容易,而编写正常的并发程序就更难了.相比于顺序执行的情况,多线程的线程安全问题是微妙而且出乎意料的,因为在没有进行适当同步的情况下多线程中各个操作 ...
Java并发编程之CAS第三篇-CAS的缺点
Java并发编程之CAS第三篇-CAS的缺点通过前两篇的文章介绍,我们知道了CAS是什么以及查看源码了解CAS原理.那么在多线程并发环境中,的缺点是什么呢?这篇文章我们就来讨论讨论本篇是<凯 ...
cyclicbarrier java_Java并发编程之CyclicBarrier和线程池的使用
原标题:Java并发编程之CyclicBarrier和线程池的使用下面我们来讲述一下线程池和CyclicBarrier的使用和对比. 一.场景描述有四个游戏玩爱好者玩游戏,游戏中有三个关卡,每一个 ...
zbb20180929 thread java并发编程之Condition
java并发编程之Condition 引言在java中,对于任意一个java对象,它都拥有一组定义在java.lang.Object上监视器方法,包括wait(),wait(long timeout ...

Go 分布式学习利器（18）-- Go并发编程之lock+WaitGroup实现线程安全

Go 分布式学习利器（18）-- Go并发编程之lock+WaitGroup实现线程安全相关推荐

最新文章

热门文章