语言并发编程学习-mutex1.1

在多个goroutine的情况下并发更新计数器得到的值可能不符合预期。

package

这个可以先不管理解为main函数需要等待goroutine都执行完才能退出可以把wg相关全去掉在main函数后面加上time.sleep(time.second

10)for

increment()}wg.Wait()fmt.Println(Final

counter:,

在用户收入和支出的时候如果不同的goroutine同时对该账户余额进行更新处理的时候可能会导致余额错误

package

withdraw(1)}wg.Wait()fmt.Println(Final

balance:,

没有互斥锁的情况下可能会出现超卖的情况。

也就是商品已经没有了但是还是可以进行出售商品商品数量减1的操作。

package

purchase()}wg.Wait()fmt.Println(Final

stock:,

}还有一些其他的场景比如并发写入buffer等等不解决并发访问的问题就会发生很严重的后果。

1.2.1.1

并发访问问题的核心在于对共享资源的非原子性操作。

临界区是指一段需要独占访问的代码块多个goroutine在执行这段代码时如果没有同步机制如互斥锁来保证互斥访问就可能会产生数据竞争导致数据不一致和其他问题。

以下从临界区的角度来解释这些问题。

下面分析多个goroutine并发更新计数器

在并发情况下如果两个goroutine同时执行这三个步骤中的任意一个步骤没有同步机制来保证这三个步骤是原子操作就会产生问题

Goroutine

可以使用上文的秒杀系统作为例子。

写这个的时候图片转存失败因此决定用极客上的图片。

在执行go

counter.go的时候会出现以下结果是可以正常运行通过的但是结果不如愿

run

这个警告不但会告诉你有并发问题,而且还会告诉你哪个goroutiine在哪一行对哪个变量有写操作,同时,哪个goroutine在哪一行对哪个变量有读操作,就是这些并发的读写访问,引起了datarace。

对内存地址0x000126010有读的操作(ctounter.go文件第16行),同时,goroutine7对内存地址0x00c000126010有写的操作(counter.go文件第16行)。

而且还可能有多个goroutine在同时进行读写,所以,警告信息可能会很长。

总结一下,通过在编译的时候插入一些指令,在运行时通过这些插入的指令检测并发读写从而发现data

既然这个例子存在data

race问题,我们就要想办法来解决它。

这个时候,我们这节课的主角Mutex就要登场了,它可以轻松地消除掉data

具体怎么做呢?下面,我就结合这个例子,来具体说一说Mutex的基本用法。

1.2.3

mutex的基本实现的机制就是每次只允许一个goroutine进入临界区具体就是进入临界区的时候给临界区加上一个锁禁止其他goroutine进入临界区在退出临界区的时候释放锁从而允许其他goroutine进入。

Mutex

purchase()}wg.Wait()fmt.Println(Final

stock:,

该使用是把mutex和临界区资源封装为一个类这样更好的进行复用不暴露内部实现

package

{sm.stock--fmt.Println(Purchase

successful,

wg.Done()sm.Purchase()}()}wg.Wait()fmt.Println(Final

stock:,