[TOC]
# 注意
* 監聽的case中,沒有滿足條件的就阻塞
* **多個滿足條件的就任選一個執行**
* select本身不帶循環,需要外層的for
* default通常不用,會產生忙輪詢
* break只能跳出select中的一個case
1. 加入了默認分支,那么無論涉及通道操作的表達式是否有阻塞,select語句都不會被阻塞。如果那幾個表達式都阻塞了,或者說都沒有滿足求值的條件,那么默認分支就會被選中并執行。
2. 如果沒有加入默認分支,那么一旦所有的case表達式都沒有滿足求值條件,那么select語句就會被阻塞。直到至少有一個case表達式滿足條件為止。
**如果select語句發現同時有多個候選分支滿足選擇條件,那么它就會用一種偽隨機的算法在這些分支中選擇一個并執行。注意,即使select語句是在被喚醒時發現的這種情況,也會這樣做**
# 作用
go里面提供了一個關鍵字select,通過**select可以監聽channel上的數據流動**
select的用法與switch語言非常類似,由select開始一個新的選擇塊,每個選擇塊條件由case語句來描述
與switch語句可以選擇任何可使用相等比較的條件相比,select有比較多的限制,其中最大的一條限制就是**每個case語句里必須是一個IO操作**
~~~
for {
select {
case <-chan1:
//.....
case chan2<-1:
//....
default:
//都沒成功,進入......
}
}
~~~
在一個select語句中,go語言會按順序從頭到尾評估每一個發送和接收的語句
如果其中的任意一語句可以繼續執行(即沒有被阻塞),那么就從哪些可以執行的語句中任意選擇一條來使用
如果沒有任意一條語句可以執行(即所有的通道都被阻塞),那么有兩種可能的情況:
* 如果給出了default語句,那么就會執行default語句,同時程序的執行會從select語句后的語句中恢復
* 如果沒有default語句,那么select語句將被阻塞,直到至少有一個通信可以進行下去
# 防止channel超時機制
有時候會出現協程阻塞的情況,那么我們如何避免這個情況?我們可以使用select來設置超時
~~~
func main() {
c := make(chan int)
o := make(chan bool)
go func() {
for {
select {
case v:= <-c:
fmt.Println(v)
//5秒鐘自動關閉,避免長時間超時
case <-time.After(5 * time.Second):
fmt.Println("timeout")
o<-true
break
}
}
}()
//有值就主協程走,主協程走完就都沒了
<-o
fmt.Println("程序結束")
}
~~~
- 基礎
- 簡介
- 主要特征
- 變量和常量
- 編碼轉換
- 數組
- byte與rune
- big
- sort接口
- 和mysql類型對應
- 函數
- 閉包
- 工作區
- 復合類型
- 指針
- 切片
- map
- 結構體
- sync.Map
- 隨機數
- 面向對象
- 匿名組合
- 方法
- 接口
- 權限
- 類型查詢
- 異常處理
- error
- panic
- recover
- 自定義錯誤
- 字符串處理
- 正則表達式
- json
- 文件操作
- os
- 文件讀寫
- 目錄
- bufio
- ioutil
- gob
- 棧幀的內存布局
- shell
- 時間處理
- time詳情
- time使用
- new和make的區別
- container
- list
- heap
- ring
- 測試
- 單元測試
- Mock依賴
- delve
- 命令
- TestMain
- path和filepath包
- log日志
- 反射
- 詳解
- plugin包
- 信號
- goto
- 協程
- 簡介
- 創建
- 協程退出
- runtime
- channel
- select
- 死鎖
- 互斥鎖
- 讀寫鎖
- 條件變量
- 嵌套
- 計算單個協程占用內存
- 執行規則
- 原子操作
- WaitGroup
- 定時器
- 對象池
- sync.once
- 網絡編程
- 分層模型
- socket
- tcp
- udp
- 服務端
- 客戶端
- 并發服務器
- Http
- 簡介
- http服務器
- http客戶端
- 爬蟲
- 平滑重啟
- context
- httptest
- 優雅中止
- web服務平滑重啟
- beego
- 安裝
- 路由器
- orm
- 單表增刪改查
- 多級表
- orm使用
- 高級查詢
- 關系查詢
- SQL查詢
- 元數據二次定義
- 控制器
- 參數解析
- 過濾器
- 數據輸出
- 表單數據驗證
- 錯誤處理
- 日志
- 模塊
- cache
- task
- 調試模塊
- config
- 部署
- 一些包
- gjson
- goredis
- collection
- sjson
- redigo
- aliyunoss
- 密碼
- 對稱加密
- 非對稱加密
- 單向散列函數
- 消息認證
- 數字簽名
- mysql優化
- 常見錯誤
- go run的錯誤
- 新手常見錯誤
- 中級錯誤
- 高級錯誤
- 常用工具
- 協程-泄露
- go env
- gometalinter代碼檢查
- go build
- go clean
- go test
- 包管理器
- go mod
- gopm
- go fmt
- pprof
- 提高編譯
- go get
- 代理
- 其他的知識
- go內存對齊
- 細節總結
- nginx路由匹配
- 一些博客
- redis為什么快
- cpu高速緩存
- 常用命令
- Go 永久阻塞的方法
- 常用技巧
- 密碼加密解密
- for 循環迭代變量
- 備注
- 垃圾回收
- 協程和纖程
- tar-gz
- 紅包算法
- 解決golang.org/x 下載失敗
- 逃逸分析
- docker
- 鏡像
- 容器
- 數據卷
- 網絡管理
- 網絡模式
- dockerfile
- docker-composer
- 微服務
- protoBuf
- GRPC
- tls
- consul
- micro
- crontab
- shell調用
- gorhill/cronexpr
- raft
- go操作etcd
- mongodb