介紹
Channel 是 Go 語言中被用來實現(xiàn)并行計算方程之間通信的類型蔓钟。其功能是允許線程間通過發(fā)送和接收來傳輸指定類型的數(shù)據(jù)。其初始值是 nil。
創(chuàng)建 Channel
創(chuàng)建 Channel 的方法如下：
var c1 chan [value type]
c1 = make([channel type] [value type], [capacity])
- [value type] 定義的是 Channel 中所傳輸數(shù)據(jù)的類型。
- [channel type] 定義的是 Channel 的類型改衩，其類型有以下三種：
- “chan” 可讀可寫——“chan int” 則表示可讀寫 int 數(shù)據(jù)的 channel
- "chan<-" 僅可寫——“chan<- float64” 則表示僅可寫64位 float 數(shù)據(jù)的 channel
- “<-chan” 僅可讀——“<-chan int” 則表示僅可讀 int 數(shù)據(jù)的 channel
- [capacity] 是一個可選參數(shù)，其定義的是 channel 中的緩存區(qū) (buffer)驯镊。如果不填則默認(rèn)該 channel 沒有緩沖區(qū) (unbuffered)葫督。對于沒有緩沖區(qū)的 channel，消息的發(fā)送和收取必須能同時完成板惑，否則會造成阻塞并提示死鎖錯誤橄镜。對于 channel 的阻塞和非阻塞將在后面詳細(xì)介紹。
比如我們想創(chuàng)建了一個讀寫 int 類型冯乘，buffer 長度 100 的 channel c1蛉鹿，則如下：
var c1 chan int
c1 = make(chan int, 100)
通過 Channel 發(fā)送和接收消息
示例代碼：
package main
import "fmt"
func main(){
//定義變量
var c1 chan int
var i1 int
//初始化 channel
c1 = make(chan int, 100)
//向 channel c1 發(fā)送（寫入）一個 int 20
c1 <- 20
//從 channel c1 接收（讀取）一個 int 并賦值給 i1
i1 = <- c1
//將 i1 打印輸出
fmt.Println("received: ", i1, " from c1")
}
運行結(jié)果：
received: 20 from c1
使用 Channel 發(fā)生死鎖
如下代碼會出現(xiàn)死鎖：
package main
import "fmt"
import "time"
func main(){
var c1 chan string
c1 = make(chan string)
func() {
time.Sleep(time.Second * 2)
c1 <- "result 1"
}()
fmt.Println("received: '", <- c1,"' from c1")
}
因為對 channel 的發(fā)送和接收動作永遠(yuǎn)不會同時發(fā)生往湿，從而阻塞造成死鎖妖异。解決該問題的方式有兩種。
避免死鎖方法一：使用 go 語句進行并行計算
package main
import "fmt"
import "time"
func main(){
var c1 chan string
c1 = make(chan string)
go func() {
time.Sleep(time.Second * 2)
c1 <- "result 1"
}()
fmt.Println("received: '", <- c1,"' from c1")
}
通過 go 語句定義發(fā)送操作的方程在另一個線程并行運行领追，這樣發(fā)送和接收操作就可以同時發(fā)生他膳，從而能夠解決死鎖問題。
避免死鎖方法二：使用 buffer
package main
import "fmt"
import "time"
func main(){
var c1 chan string
c1 = make(chan string,1) //這里我們設(shè)置了一個長度為 1 的 buffer
func() {
time.Sleep(time.Second * 2)
c1 <- "result 1"
}()
fmt.Println("received: '", <- c1,"' from c1")
}
為 channel 添加一個緩沖區(qū)（buffer）绒窑，這樣只要 buffer 沒有用盡棕孙，阻塞就不會發(fā)生，死鎖也不會發(fā)生些膨。
即使有 buffer蟀俊，如果當(dāng)一個 channel 并沒有多余的數(shù)據(jù)發(fā)送進來時，你做出接收消息的動作也會造成 channel 的阻塞和死鎖订雾。合理使用 select 語句可以規(guī)避該問題肢预，詳見：golang channel阻塞與非阻塞用法
