[TOC]
# 簡介
如果使用用戶級線程,我們就不得不既是指令下達者,又是指令執行者。我們必須全權負責與用戶級線程有關的所有具體實現。
操作系統不但不會幫忙,還會要求我們的具體實現必須與它正確地對接,否則用戶級線程就無法被并發地,甚至正確地運行。畢竟我們編寫的所有代碼最終都需要通過操作系統才能在計算機上執行
不過別擔心,Go 語言不但有著獨特的并發編程模型,以及**用戶級線程 goroutine,還擁有強大的用于調度 goroutine、對接系統級線程的調度器。**
這個調度器是 Go 語言運行時系統的重要組成部分,它主要負責統籌調配 Go 并發編程模型中的三個主要元素,即:G(goroutine 的縮寫)、P(processor 的縮寫)和 M(machine 的縮寫)
其中的 M 指代的就是系統級線程。而 P 指的是一種可以承載若干個 G,且能夠使這些 G 適時地與 M 進行對接,并得到真正運行的中介。
從宏觀上說,G 和 M 由于 P 的存在可以呈現出多對多的關系。當一個正在與某個 M 對接并運行著的 G,需要因某個事件(比如等待 I/O 或鎖的解除)而暫停運行的時候,調度器總會及時地發現,并把這個 G 與那個 M 分離開,以釋放計算資源供那些等待運行的 G 使用。
而當一個 G 需要恢復運行的時候,調度器又會盡快地為它尋找空閑的計算資源(包括 M)并安排運行。另外,當 M 不夠用時,調度器會幫我們向操作系統申請新的系統級線程,而當某個 M 已無用時,調度器又會負責把它及時地銷毀掉。
正因為調度器幫助我們做了很多事,所以我們的 Go 程序才總是能高效地利用操作系統和計算機資源。程序中的所有 goroutine 也都會被充分地調度,其中的代碼也都會被并發地運行,即使這樣的 goroutine 有數以十萬計,也仍然可以如此

**一定要注意,go函數真正被執行的時間,總會與其所屬的go語句被執行的時間不同。當程序執行到一條go語句的時候,Go 語言的運行時系統,會先試圖從某個存放空閑的 G 的隊列中獲取一個 G(也就是 goroutine),它只有在找不到空閑 G 的情況下才會去創建一個新的 G**
# 控制數量
用runtime.GOMAXPROCS(maxProcs)來控制P的數量
**控制協程的數量**
我們先創建一個通道,它的長度應該與我們手動啟用的 goroutine 的數量一致。在每個手動啟用的 goroutine 即將運行完畢的時候,我們都要向該通道發送一個值
~~~
import (
"fmt"
)
func main() {
num := 10
sign := make(chan struct{}, num)
for i := 0; i < num; i++ {
go func() {
fmt.Println(i)
sign <- struct{}{}
}()
}
for j := 0; j < num; j++ {
<-sign
}
}
~~~
其中有一個細節你需要注意。我在聲明通道sign的時候是以chan struct{}作為其類型的。其中的類型字面量struct{}有些類似于空接口類型interface{},它代表了既不包含任何字段也不擁有任何方法的空結構體類型。
注意,struct{}類型值的表示法只有一個,即:struct{}{}。并且,它占用的內存空間是0字節。確切地說,這個值在整個 Go 程序中永遠都只會存在一份。雖然我們可以無數次地使用這個值字面量,但是用到的卻都是同一個值
- 基礎
- 簡介
- 主要特征
- 變量和常量
- 編碼轉換
- 數組
- 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