go并发编程

栏目: Go · 发布时间: 6年前

  1. Concurrentcy is not parallelism: Different concurrent designs enable different ways to parallelize
tip:与defer一样,go程也会因“延迟执行”而立即复制参数
关键方法:runtime.GOMAXPROCS();runtime.NumCPU;runtime.Gosched();runtime.Goexit()【会保证所有延迟调用执行】;在main.main中调用Goexit,会在等待其他任务结束后,直接崩溃;
  1. 进程退出时不会等待 go 程结束
方案1:通道channel阻塞,然后发送退出信号,主线程 <-ch,go程中执行 close(sh),(此例只针对单个任务)
方案2:使用sync.WaitGroup方法,使用时计数器在go程外添加
  1. 通道
采用经典的CSP模型,有缓冲的为异步通道,无缓冲的为同步通道,通道本质为消息队列
收发:可使用ok-idom或range模式处理数据,x, ok := <-ch ok判断通道是否关闭;
     及时使用close函数关闭通道引发结束通知,否则可能导致死锁
     一次性时间用close效率更好,没有多余开销,连续或多样性时间,可传递不同数据标志实现。还可以使用sync.Cond实现单播或广播事件。
     .向已关闭的通道发送数据,引发panic
     .从已关闭通道接收数据,返回已缓冲数据或零值
     .无论收发,nil通道都会阻塞
     重复关闭,或关闭nil通道都会引发panic错误
     
单向通道:使用类型转换来获取单向通道,并分别赋予操作双方
     .不能在单向通道上做逆向操作
     .clole不能用于接收端
     .不能将单向通道重新转换回去
     c := make(chan int)
     var send chan<- int = c
     var recv <-chan int = c
     
select:同时处理多个通道使用,如果要等全部通道消息处理结束(closed),可将已完成通道设置成nil,这些通道就会被阻塞,不在被select选中。
     .即便是同一通道,也会随机选择case执行
  1. 同步
tip:通道并非用来取代锁的,通道倾向于解决逻辑层次的并发处理架构,
而锁是用来保护局部范围内的数据安全

将Mutex作为匿名字段时,相关方法必须实现为pointer-receiver,
否则会因复制导致锁机制失效;也可以嵌套*Mutex来避免复制,但需要专门的初始化

Mutex不支持递归锁,即便在同一goroutine下也会导致死锁

.对性能要求较高时,应避免使用defer Unlock
.读写并发时,用RWMutex性能会更好一些
.对单个数据读写保护,可尝试使用原子操作
.执行严格测试,尽可能打开数据竞争检查

以上就是本文的全部内容,希望本文的内容对大家的学习或者工作能带来一定的帮助,也希望大家多多支持 码农网

查看所有标签

猜你喜欢:

本站部分资源来源于网络,本站转载出于传递更多信息之目的,版权归原作者或者来源机构所有,如转载稿涉及版权问题,请联系我们

产品经理手册(原书第4版)(白金版)

产品经理手册(原书第4版)(白金版)

[美] 琳达·哥乔斯(Linda Gorchels) / 祝亚雄、冯华丽、金骆彬 / 机械工业出版社 / 2017-8 / 65.00

产品经理的职责起点是新产品开发,贯穿产品生命周期的全过程。本书按上下游产品管理进行组织。 在上游的新产品开发流程中,作者阐述了如何从市场、产品、行业、公司的角度规划企划方案,并获得老板、销售部、运营部的资源支持,推进新产品的项目流程,实现所有目标,制定和实施新产品发布。 下游产品的管理核心在于生命周期的管理,营销更是生命周期管理的重中之重。产品经理如何让产品满足客户需求,让客户获得对产......一起来看看 《产品经理手册(原书第4版)(白金版)》 这本书的介绍吧!

URL 编码/解码
URL 编码/解码

URL 编码/解码

HEX HSV 转换工具
HEX HSV 转换工具

HEX HSV 互换工具

HSV CMYK 转换工具
HSV CMYK 转换工具

HSV CMYK互换工具