您当前的位置:首页 > 电脑百科 > 程序开发 > 语言 > Go语言

Go并发,虽然官方推荐 channel,但到底是channel还是锁?

时间:2019-08-15 11:34:13  来源:  作者:

来,问自己个问题:面对并发问题,是用channel解决,还是用Mutex解决

如果自己心里还没有清晰的答案,那就读下这篇文章,你会了解到:

  • 使用channel解决并发问题的核心思路和示例
  • channel擅长解决什么样的并发问题,Mutex擅长解决什么样的并发问题
  • 一个并发问题该怎么入手解解决
  • 一个重要的plus思维

前戏

前面很多篇的文章都在围绕channel介绍,而只有前一篇sync的文章介绍到了Mutex,不是我偏心,而是channel在Golang是first class级别的,设计在语言特性中的,而Mutex只是一个包中的。这就注定了一个是主角,一个是配角。

并且Golang还有一个并发座右铭,在《Effective Go》的channel介绍中写到:

Share memory by communicating, don’t communicate by sharing memory.通过通信共享内存,而不是通过共享内存而通信。

Golang以如此明显的方式告诉我们:面对并发问题,你首先想到的应该是channel,因为channel是线程安全的并且不会有数据冲突,比锁好用多了

既生瑜,何生亮。既然有channel了,为啥还提供sync.Mutex呢?

主角不是万能的,他也需要配角。在Golang里,channel也不是万能的,这是由channel的特性和局限造成的。

下面就给大家介绍channel的特点、核心方法和缺点。

channel解决并发问题的思路和示例

channel的核心是数据流动,关注到并发问题中的数据流动,把流动的数据放到channel中,就能使用channel解决这个并发问题。这个思路是从Go语言的核心开发者的演讲中学来的,然而视频我已经找不到了,不然直接共享给大家,他提到了Golang并发的核心实践的4个点:

DataFlow -> Drawing -> Pipieline -> Exiting

 

DataFlow指数据流动,Drawing指把数据流动画出来,Pipeline指的是流水线,Exit指协程的退出。DataFlow + Drawing就是我提到到channel解决并发问题的思路,Pipeline和Exit是具体的实践模式,Pipeline和Exit我都写过文章,有需要自取:

  • Golang 并发模型系列:1. 轻松入门流水线模型
  • Golang 并发模型系列:2. 轻松入门流水线FAN模式
  • Golang 并发模型系列:3. 并发协程的优雅退出

下面我使用例子具体解释DataFlow + Drawing。借用《Golang并发模型系列:7. sync 包》中银行的例子,介绍如何使用channel解决例子中银行的并发问题:银行支持多个用户的同时操作。顺便看下同一个并发问题,使用channel和Mutex解决是什么差别。

一起分析下多个用户同时操作银行的数据流动:

  1. 每个人都可以向银行发起请求,请求可以是存、取、查3种操作,并且包含操作时必要的数据,包含的数据只和自身相关。
  2. 银行处理请求后给用户发送响应,包含的数据只和操作用户相关。

 

Go并发,虽然官方推荐 channel,但到底是channel还是锁?

 

 

你一定发现了上面的数据流动:

  1. 请求数据:个人请求数据流向银行。
  2. 响应数据:银行处理结果数据流向用户。

channel是数据流动的通道/管道,为流动的数据建立通道,这里需要建立2类channel:

  1. reqCh:传送请求的channel,把请求从个人发送给银行。
  2. retCh:传送响应的channel,把响应从银行发给个人。

我们把channel添加到上图中,得到下面的图:

Go并发,虽然官方推荐 channel,但到底是channel还是锁?

 

 

以上就是从数据流动的角度,发现如何使用channel解决并发问题。思路有了,再思考下代码层面需要怎么做:

  1. 银行:
  2. 定义银行,只保存1个map即可
  3. 银行操作:接收和解析请求,并把请求分发给存、取、查函数
  4. 实现存、取、查函数:处理请求,并把结果写入到用户提供的响应通道
  5. 定义请求和响应
  6. 用户:创建请求和接收响应的通道,发送请求后等待响应,提取响应结果
  7. mian函数:创建银行和用户间的请求通道,创建银行、用户等协程,并等待操作完成

以上,我们这个并发问题的逻辑实现和各块工作就清晰了,写起来也方便、简单。代码实现有200多行。

代码不能贴了,运行结果还是可以的,为了方便理解结果,介绍下示例代码做了什么。main函数创建了银行、小明、小刚3个并发协程:

  1. 银行:从reqCh接收请求,依次处理每个请求,直到通道关闭,把请求交给处理函数,处理函数把结果写入到请求中的retCh。
  2. 用户小明:创建了存100、取20、查余额的3个请求,每个请求得到响应后,再把下一个请求写入到reqCh。
  3. 用户小刚:流程和小明相同,但存100取200,造成取钱操作失败,他查询下自己又多少钱,得到100。

main函数最后使用WaitGroup等待小明、小刚结束后退出。

下面是运行结果:

$ go run channel_map.go
xiaogang deposite 100 success
xiaoming deposite 100 success
xiaogang withdraw 200 failed
xiaoming withdraw 20 success
xiaogang has 100
xiaoming has 80
Bank exit

这一遭搞完,发现啥没有?用Mutex直接加锁、解锁完事了,但channel搞出来一坨,是不是用channel解决这个问题不太适合?是的。对于当前这个问题,和Mutex的方案相比,channel的方案显的有点“重”,不够简洁、高效、易用

但这个例子展示了3点:

  1. 使用channel解决并发问题的核心在于关注数据的流动
  2. channel不一定是某个并发问题最好的解决方案
  3. map在并发中,可以不用锁进行保护,而是使用channel

现在,回到了开篇的问题:同一个并发问题,你是用channel解决,还是用mutex解决?下面,一起看看怎么选择。

channel和mutex的选择

面对一个并发问题的时候,应当选择合适的并发方式:channel还是mutex。选择的依据是他们的能力/特性:channel的能力是让数据流动起来,擅长的是数据流动的场景,《Channel or Mutex》中给了3个数据流动的场景:

  1. 传递数据的所有权,即把某个数据发送给其他协程
  2. 分发任务,每个任务都是一个数据
  3. 交流异步结果,结果是一个数据

mutex的能力是数据不动,某段时间只给一个协程访问数据的权限擅长数据位置固定的场景,《Channel or Mutex》中给了2个数据不动场景:

  1. 缓存
  2. 状态,我们银行例子中的map就是一种状态

提供解决并发问题的一个思路

  1. 先找到数据的流动,并且还要画出来,数据流动的路径换成channel,channel的两端设计成协程
  2. 基于画出来的图设计简要的channel方案,代码需要做什么
  3. 这个方案是不是有点复杂,是不是用Mutex更好一点?设计一个简要的Mutex方案,对比&选择易做的、高效的

channel + mutex思维

面对并发问题,除了channel or mutex,你还有另外一个选择:channel plus mutex

一个大并发问题,可以分解成很多小的并发问题,每个小的并发都可以单独选型:channel or mutex。但对于整个大的问题,通常不是channel or mutex,而是channel plus mutex。

如果你是认为是channel and mutex也行,但我更喜欢plus,体现相互配合

总结

读到这里,感觉这篇文章头重脚轻,channel的讲了很多,而channel和mutex的选择却讲的很少。在channel和mutex的选择,实际并没有一个固定答案,也没有固定的方法,但提供了一个简单的思路:设计出channel和Mutex的简单方案,然后选择最适合当前业务、问题的那个。

思考比结论更重要,希望你有所收获

  1. 关注数据的流动,就可以使用channel解决并发问题。
  2. 不流动的数据,如果存在并发访问,尝试使用sync.Mutex保护数据。
  3. channel不一定某个并发问题的最优解。
  4. 不要害怕、拒绝使用mutex,如果mutex是问题的最优解,那就大胆使用。
  5. 对于大问题,channel plus mutex也许才是更好的方案。

参考资料

  1. 《Effective Go》,https://golang.org/doc/effective_go.html#sharing
  2. 《Mutex Or Channel》,https://github.com/golang/go/wiki/MutexOrChannel


Tags:Go并发   点击:()  评论:()
声明:本站部分内容及图片来自互联网,转载是出于传递更多信息之目的,内容观点仅代表作者本人,如有任何标注错误或版权侵犯请与我们联系(Email:2595517585@qq.com),我们将及时更正、删除,谢谢。
▌相关推荐
来,问自己个问题:面对并发问题,是用channel解决,还是用Mutex解决?如果自己心里还没有清晰的答案,那就读下这篇文章,你会了解到: 使用channel解决并发问题的核心思路和示例 channel擅...【详细内容】
2019-08-15  Tags: Go并发  点击:(195)  评论:(0)  加入收藏
▌简易百科推荐
zip 是一种常见的归档格式,本文讲解 Go 如何操作 zip。首先看看 zip 文件是如何工作的。以一个小文件为例:(类 Unix 系统下)$ cat hello.textHello!执行 zip 命令进行归档:$ zip...【详细内容】
2021-12-17  Go语言中文网    Tags:Go语言   点击:(13)  评论:(0)  加入收藏
大家好,我是 polarisxu。前段时间,Russ Cox 明确了泛型相关的事情,原计划在标准库中加入泛型相关的包,改放到 golang.org/x/exp 下。目前,Go 泛型的主要设计者 ianlancetaylor 完...【详细内容】
2021-11-30  Go语言中文网    Tags:slices 包   点击:(24)  评论:(0)  加入收藏
前言最近因为项目需要写了一段时间的 Go ,相对于 Java 来说语法简单同时又有着一些 Python 之类的语法糖,让人大呼”真香“。 但现阶段相对来说还是 Python 写的多一些,偶尔还...【详细内容】
2021-11-25  crossoverJie    Tags:Go   点击:(29)  评论:(0)  加入收藏
go-micro是基于 Go 语言用于开发的微服务的 RPC 框架,主要功能如下:服务发现,负载均衡 ,消息编码,请求/响应,Async Messaging,可插拔接口,最后这个功能牛p安装步骤安装proto...【详细内容】
2021-09-06    石老师小跟班  Tags:go-micro   点击:(197)  评论:(0)  加入收藏
GoLand 2021.2 EAP 5 现已发布。用户可以从工具箱应用程序中获得 EAP 构建,也可以从官方网站手动下载。并且从此 EAP 开始,只有拥有有效的 JetBrains 帐户才能加入该计划。手...【详细内容】
2021-06-29  IT实战联盟  今日头条  Tags:GoLand   点击:(185)  评论:(0)  加入收藏
作者:HDT3213今天给大家带来的开源项目是 Godis:一个用 Go 语言实现的 Redis 服务器。支持: 5 种数据结构(string、list、hash、set、sortedset) 自动过期(TTL) 发布订阅、地理位...【详细内容】
2021-06-18  HelloGitHub  今日头条  Tags:Go   点击:(125)  评论:(0)  加入收藏
统一规范篇合理规划目录本篇主要描述了公司内部同事都必须遵守的一些开发规矩,如统一开发空间,既使用统一的开发工具来保证代码最后的格式的统一,开发中对文件和代码长度的控制...【详细内容】
2021-05-18  1024课堂    Tags:Go语言   点击:(232)  评论:(0)  加入收藏
闭包概述 闭包不是Go语言独有的概念,在很多编程语言中都有闭包 闭包就是解决局部变量不能被外部访问的一种解决方案 是把函数当作返回值的一种应用 代码演示总体思想:在函数...【详细内容】
2021-05-14  HelloGo  今日头条  Tags:Go语言   点击:(223)  评论:(0)  加入收藏
一时想不开,想了解一下Go语言,于是安装了并体验了一下。下载1. 进入golang.google.cn 点击Download Go 2.选择对应的操作系统,点击后开始下载。 安装1. windows下执行傻瓜式安...【详细内容】
2021-05-12  程序员fearlazy  fearlazy  Tags:Go语言   点击:(236)  评论:(0)  加入收藏
1.简介channel是Go语言的一大特性,基于channel有很多值得探讨的问题,如 channel为什么是并发安全的? 同步通道和异步通道有啥区别? 通道为何会阻塞协程? 使用通道导致阻塞的协程...【详细内容】
2021-05-10  程序员麻辣烫  今日头条  Tags:Go通道   点击:(274)  评论:(0)  加入收藏
相关文章
    无相关信息
最新更新
栏目热门
栏目头条