## 信道(channel)
信道可以想像成 Go 協程之間通信的管道。如同管道中的水會從一端流到另一端,通過使用信道,數據也可以從一端發送,在另一端接收;
所有信道都關聯了一個類型。信道只能運輸這種類型的數據,而運輸其他類型的數據都是非法的;
信道的零值為`nil`;
### channel聲明
語法:
~~~go
var a chan int // 申明
a := make(chan int) // 簡潔語法
data := <- a // 讀取信道 a
a <- data // 寫入信道 a
~~~
### 死鎖
* 當Go協程給一個信道發送數據時,如果沒有其他 Go 協程來接收數據,程序就會在運行時觸發 panic,形成死鎖
* 當有Go協程等著從一個信道接收數據時,如果沒有其他的 Go 協程向該信道寫入數據,則會觸發 panic
* 向容量為 2 的緩沖信道寫入 3 個字符串
~~~go
func main() {
ch := make(chan string, 2)
ch <- "naveen"
ch <- "paul"
ch <- "steve"
fmt.Println(<-ch)
fmt.Println(<-ch)
}
~~~
## 關閉信道和使用 for range 遍歷信道
數據發送方可以關閉信道,通知接收方這個信道不再有數據發送過來;
當從信道接收數據時,接收方可以多用一個變量來檢查信道是否已經關閉
~~~
v, ok := <- ch
~~~
如果成功接收信道所發送的數據,那么`ok`等于 true。而如果`ok`等于 false,說明我們試圖讀取一個關閉的通道。從關閉的信道讀取到的值會是該信道類型的零值
示例:
~~~go
func producer(chnl chan int) {
for i := 0; i < 10; i++ {
chnl <- i
}
close(chnl)
}
func main() {
ch := make(chan int)
go producer(ch)
for {
v, ok := <-ch
if ok == false {
break
}
fmt.Println("Received ", v, ok)
}
}
~~~
使用range接收信道數據
~~~go
func producer(chnl chan int) {
for i := 0; i < 10; i++ {
chnl <- i
}
close(chnl)
}
func main() {
ch := make(chan int)
go producer(ch)
for v := range ch {
fmt.Println("Received ",v)
}
}
~~~
## future模式
~~~
func RunTask() chan string {
result := make(chan string)
go func() {
fmt.Println("處理異步任務。。。")
time.Sleep(2 * time.Second)
result <- "success"
}()
return result
}
func TestFutureTaskStudy(t *testing.T) {
result := RunTask()
fmt.Println("main gorouting running")
fmt.Println("task result:", <-result)
}
~~~
## 關閉channel
v,ok <- ch; ok為bool值,true表示正常接受;false表示同道關閉
所有的channel接收者都會在channel關閉時,立刻從阻塞等待中返回且返回狀態值為false;這個廣播機制通常被用來向多個訂閱者同時發送信號;
使用channel實現生產者消費者模式:
~~~
var wg sync.WaitGroup
var messageQueue chan int = make(chan int)
func ProducerMessage() {
for i := 1; i <= 20; i++ {
messageQueue <- i
fmt.Println("生產者生產數據:", i)
}
close(messageQueue)
wg.Done()
}
func ConsumerMessage1() {
for {
v, ok := <-messageQueue
if !ok {
fmt.Println("channel closed")
break
}
fmt.Println("ConsumerMessage-1:", v)
}
}
func ConsumerMessage2() {
for {
v, ok := <-messageQueue
if !ok {
fmt.Println("channel closed")
break
}
fmt.Println("ConsumerMessage-2:", v)
}
}
func TestMessageTopic(t *testing.T) {
wg.Add(1)
go ProducerMessage()
go ConsumerMessage1()
go ConsumerMessage2()
wg.Wait()
fmt.Println("main goroutine end")
}
~~~
*****
【知識點】
* 無緩沖信道的發送和接收過程是阻塞的
~~~go
func hello(done chan bool) {
fmt.Println("hello go routine is going to sleep")
time.Sleep(4 * time.Second)
fmt.Println("hello go routine awake and going to write to done")
done <- true
}
func main() {
done := make(chan bool)
fmt.Println("Main going to call hello go goroutine")
go hello(done)
<-done
fmt.Println("Main received data")
}
~~~
- 概述
- go語言基礎特性
- Go語言聲明
- Go項目構建及編譯
- go command
- 程序設計原則
- Go基礎
- 變量
- 常量
- iota
- 基本類型
- byte和rune類型
- 類型定義和類型別名
- 數組
- string
- 高效字符串連接
- string底層原理
- 運算符
- new
- make
- 指針
- 下劃線 & import
- 語法糖
- 簡短變量申明
- 流程控制
- ifelse
- switch
- select
- select實現原理
- select常見案例
- for
- range
- range實現原理
- 常見案例
- range陷阱
- Goto&Break&Continue
- Go函數
- 函數
- 可變參數函數
- 高階函數
- init函數和main函數
- 匿名函數
- 閉包
- 常用內置函數
- defer
- defer常見案例
- defer規則
- defer與函數返回值
- defer實現原理
- defer陷阱
- 數據結構
- slice
- slice內存布局
- slice&array
- slice底層實現
- slice陷阱
- map
- Map實現原理
- 集合
- List
- Set
- 線程安全數據結構
- sync.Map
- Concurrent Map
- 面向對象編程
- struct
- 匿名結構體&匿名字段
- 嵌套結構體
- 結構體的“繼承”
- struct tag
- 行為方法
- 方法與函數
- type Method Value & Method Expressions
- interface
- 類型斷言
- 多態
- 錯誤機制
- error
- 自定義錯誤
- panic&recover
- reflect
- reflect包
- 應用示例
- DeepEqual
- 反射-fillObjectField
- 反射-copyObject
- IO
- 讀取文件
- 寫文件
- bufio
- ioutil
- Go網絡編程
- tcp
- tcp粘包
- udp
- HTTP
- http服務
- httprouter
- webSocket
- go并發編程
- Goroutine
- thread vs goroutine
- Goroutine任務取消
- 通過channel廣播實現
- Context
- Goroutine調度機制
- goroutine調度器1.0
- GMP模型調度器
- 調度器竊取策略
- 調度器的生命周期
- 調度過程全解析
- channel
- 無緩沖的通道
- 緩沖信道
- 單向信道
- chan實現原理
- 共享內存并發機制
- mutex互斥鎖
- mutex
- mutex原理
- mutex模式
- RWLock
- 使用信道處理競態條件
- WaitGroup
- 工作池
- 并發任務
- once運行一次
- 僅需任意任務完成
- 所有任務完成
- 對象池
- 定時器Timer
- Timer
- Timer實現原理
- 周期性定時器Ticker
- Ticker對外接口
- ticker使用場景
- ticker實現原理
- ticker使用陷阱
- 包和依賴管理
- package
- 依賴管理
- 測試
- 單元測試
- 表格測試法
- Banchmark
- BDD
- 常用架構模式
- Pipe-filter pattern
- Micro Kernel
- JSON
- json-內置解析器
- easyjson
- 性能分析
- gc
- 工具類
- fmt
- Time
- builtin
- unsafe
- sync.pool
- atomic
- flag
- runtime
- strconv
- template