Golang 并发concurrency
并发concurrency
- 很多人都是冲着Go大肆宣扬的高并发而忍不住跃跃欲试,但其实从源码解析来看,goroutine只是由官方实现的超级“线程池”而已。不过话说回来,每个实例4-5KB的栈内存占用和由于实现机制而大幅减少的创建和销毁开销,是制造Go号称的高并发的根本原因。另外goroutine的简单易用,也在语言层面上给予了开发者的巨大的便利。
并发不是并行 Concurrency Is Not Parallelism - 并发主要由切换时间片来实现“同时”运行,在并行则是直接利用多核实现多线程的运行,但Go可以设置使用核数,以发挥多核计算机的能力
- Goroutine 奉行通过通信来共享内存,而不是共享内存来通信。
Channel
- Channel 是 goroutine 沟通的桥梁,大都是阻塞同步的
- 通过 make 创建,close 关闭
- Channel 是引用类型
- 可以使用 for range 来迭代不断操作 channel
- 可以设置单向或双向通道
- 可以设置缓存大小,在未被填满前不会发生阻塞
通过 make 创建,close 关闭
package mainimport ("fmt"
)func main() {c := make(chan bool) //声明一个channelgo func() {fmt.Println("GOOD---")c <- true //存入这个channel}()<-c //取出这个channel//当这个main函数执行的时候,遇到gorouting时会直接执行到<-c,此时这个程序会阻塞,一直等到有true存入这个channel(c<-true),此时(<-c)才能读出来,main函数完成
}
可以使用 for range 来迭代不断操作 channel
package mainimport ("fmt"
)func main() {c := make(chan bool)go func() {fmt.Println("GOOD---")c <- trueclose(c) //关闭这个channel,迭代操作会终止}()for v := range c {fmt.Println(v)}
}
可以设置缓存大小,在未被填满前是异步的,不会发生阻塞
package mainimport ("fmt""runtime"
)func main() {runtime.GOMAXPROCS(runtime.NumCPU()) //1.8默认使用多核CPUc := make(chan bool, 10)for i := 0; i < 10; i++ {go Go(c, i)}for i := 0; i < 10; i++ {<-c}}
func Go(c chan bool, index int) {a := 1for i := 0; i < 1000000; i++ {a += i}fmt.Println(index, a)c <- true}/*
如果设置了缓存大小,大小在未被填满之前,它是异步的,不会发生阻塞
如果这个channel没有缓存的话,要注意取出的操作要在写入的操作的前面
*/
package mainimport ("fmt""runtime""sync"
)func main() {runtime.GOMAXPROCS(runtime.NumCPU()) //1.8默认使用多核CPUwg := sync.WaitGroup{}wg.Add(10)for i := 0; i < 10; i++ {go Go(&wg, i)}wg.Wait() //通过同步包来实现多个gorouting同步内容}
func Go(wg *sync.WaitGroup, index int) {a := 1for i := 0; i < 1000000; i++ {a += i}fmt.Println(index, a)wg.Done()}/*
如果设置了缓存大小,大小在未被填满之前,它是异步的,不会发生阻塞
如果这个channel没有缓存的话,要注意取出的操作要在写入的操作的前面
*/
Select
- 可处理一个或多个 channel 的发送与接收
- 同时有多个可用的 channel时按随机顺序处理
- 可用空的 select 来阻塞 main 函数
- 可设置超时
package mainimport ("fmt"
)func main() {c1, c2 := make(chan int), make(chan string)o := make(chan bool)go func() {for {select {case v, ok := <-c1:if !ok {o <- truebreak}fmt.Println("c1", v)case v, ok := <-c2:if !ok {o <- truebreak}fmt.Println("c2", v)}}}()c1 <- 1c2 <- "hi"c1 <- 3c2 <- "hello"close(c1)close(c2)<-o
}
select设置超时
package mainimport ("fmt""time"
)func main() {c := make(chan bool)select {case v := <-c:fmt.Println(v)case <-time.After(3 * time.Second): //返回的是一个time类型的chanfmt.Println("TimeOut")}
}
转载于:https://www.cnblogs.com/skymyyang/p/7697844.html
Golang 并发concurrency相关推荐
- golang 并发demo 写入 redis
原文链接:golang 并发demo 写入 redis 源代码: package mainimport ("fmt""runtime""strconv ...
- Golang 并发编程指南
分享 Golang 并发基础库,扩展以及三方库的一些常见问题.使用介绍和技巧,以及对一些并发库的选择和优化探讨. go 原生/扩展库 提倡的原则 不要通过共享内存进行通信;相反,通过通信来共享内存. ...
- Golang并发模型:轻松入门协程池
goroutine是非常轻量的,不会暂用太多资源,基本上有多少任务,我们可以开多少goroutine去处理.但有时候,我们还是想控制一下. 比如,我们有A.B两类工作,不想把太多资源花费在B类务上,而 ...
- [导入]ADO.NET Entity Framework 深入分析, Part 6 – 处理并发(Concurrency Handling)
摘要: ADO.NET Entity Framework 深入分析, Part 6 – 处理并发(Concurrency Handling)前面的Part 1-4的文章,介绍了Entity Data ...
- Golang并发模型:合理退出并发协程
goroutine作为Golang并发的核心,我们不仅要关注它们的创建和管理,当然还要关注如何合理的退出这些协程,不(合理)退出不然可能会造成阻塞.panic.程序行为异常.数据结果不正确等问题.这篇 ...
- 4种Golang并发操作中常见的死锁情形
摘要:什么是死锁,在Go的协程里面死锁通常就是永久阻塞了,你拿着我的东西,要我先给你然后再给我,我拿着你的东西又让你先给我,不然就不给你.我俩都这么想,这事就解决不了了. 本文分享自华为云社区< ...
- Golang并发:再也不愁选channel还是选锁
周末又到了,为大家准备了一份实用干货:如何使用channel和Mutex解决并发问题,利用周末的好时光,配上音乐,思考一下吧?. 来,问自己个问题:面对并发问题,是用channel解决,还是用Mute ...
- golang并发编程之Ticker
golang并发编程之Ticker Timer只执行一次,Ticker可以周期的执行 icker是一个定时触发的计时器 它会以一个间隔(interval)往channel发送一个事件(当前时间) 而c ...
- Golang并发模型:轻松入门流水线FAN模式
前一篇文章<Golang并发模型:轻松入门流水线模型>,介绍了流水线模型的概念,这篇文章是流水线模型进阶,介绍FAN-IN和FAN-OUT,FAN模式可以让我们的流水线模型更好的利用Gol ...
最新文章
- 旷视CEO竟遭监听敲诈:不给300万就卖敏感信息录音!网友:利好无人驾驶?
- VS2015编译32位Opencv310(动态库+静态库,文末有下载链接)
- easyui 初体验
- C语言 实现一个函数判断year是不是润年
- 查看高通kernel用哪个dsti
- ArcGIS pro 发布地图服务(一)动态地图服务
- 发那科机器人注油_安川机器人加油保养流程
- 注册表右键取得管理员权限
- cadence ~ PCB排版 必要流程
- windows 域介绍
- 使用Hbase Shell和Java API分别进行Hbase的增删改查操作
- 客户案例 | 初窥元宇宙,Oasis让更多人找到第二人生
- 制作动态图表,没有比这个方法更简单的了
- Plane(Fixed Wing) ——ArduPilot——飞行模式
- JS小练习:使用JavaScript实现点击‘上一张’,‘下一张’循环播放图片
- EL表达式、JSTL标签库、文件上传和下载
- 万科为并购平台投资39亿,王石退路浮出水面
- matlab 离散控制系统仿真,实验二-基于Matlab的离散控制系统仿真.doc
- Oracle 12c 的安装
- 若依ruoyi菜单验证
热门文章
- Windows(64位IIS)未在本地计算机上注册“Microsoft.Jet.OLEDB.4.0”提供程序
- LoadRunner系统架构简介与运行原理
- 表单FORM的5个属性name,method,action,enctype,target
- Windows的位图alpha混合技术
- 《JAVA练习题目11》学生类有属性姓名(字符串类型)和选修课程信息(ArrayList<Course>对象)两个属性,和三个方法
- R语言常用包分类总结
- xp系统的计算机管理中用户在哪里,XP系统设备管理器中一片空白怎么修复?
- java php 单点登陆,cas实现单点登录,登出(java跟php客户端)(转)
- oracle表数据转换成sql,ORACLE8I转换数据到SQLSERVER数据库
- java 反射 修改字段_Java反射机制-修改字段值