Java的并發(fā):基于線程
Golang的并發(fā):基于協(xié)程goroutine
并發(fā)會(huì)導(dǎo)致資源競爭:加鎖
防止資源競爭的三種方式:
- 原子函數(shù):atomic.LoadInt32,atomic.StoreInt32
- 互斥鎖:mutex sync.Mutex, mutex.Lock(), mutex.Unlock()
- 通道:channel
通道Channel
聲明
使用chan聲明通道,并指明需要發(fā)送和接收的數(shù)據(jù)類型。例如:
ch := make(chan int)
聲明通道可以有第二個(gè)參數(shù),用來指定通道大小。
ch := make(chan int)
ch := make(chan int, 0)
ch := make(chan int, 2)
第一種和第二種等價(jià),都為無緩沖通道。第三種為有緩沖通道,容量為2。
發(fā)送和接收
使用操作符 -> 進(jìn)行發(fā)送和接收
ch <- 2 //發(fā)送數(shù)值2給這個(gè)通道
x: = <-ch //從通道里讀取值,并把讀取的值賦值給x變量
<- ch //從通道里讀取值,然后忽略
關(guān)閉
當(dāng)通道關(guān)閉時(shí),就不能再往通道發(fā)送數(shù)據(jù)了,但是可以從通道接收數(shù)據(jù)。
close(ch)
通道緩沖
- 無緩沖通道
無緩沖通道,如果發(fā)送和接收有一方還沒有準(zhǔn)備好的話,先執(zhí)行的一方會(huì)阻塞直到另一方操作結(jié)束。無緩沖通道也稱為同步通道。 - 有緩沖通道
有緩沖通道類似于隊(duì)列。發(fā)送操作即向隊(duì)列的尾部插入一條數(shù)據(jù)。接收操作類似刪除隊(duì)列頭部數(shù)據(jù),并返回刪除的這條數(shù)據(jù)。
單向通道
var send chan<- int //只能發(fā)送
var receive <-chan int //只能接收