go并发编程

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性能会更好一些
.对单个数据读写保护,可尝试使用原子操作
.执行严格测试,尽可能打开数据竞争检查

本文来自:Segmentfault

感谢作者:氓浅

查看原文:go并发编程

• 编辑
• 预览