# Go 工作池
在這個例子中,我們來看一下如何使用gorouotine和channel來實現工作池。
```go
package main
import "fmt"
import "time"
// 我們將在worker函數里面運行幾個并行實例,這個函數從jobs通道
// 里面接受任務,然后把運行結果發送到results通道。每個job我們
// 都休眠一會兒,來模擬一個耗時任務。
func worker(id int, jobs <-chan int, results chan<- int) {
for j := range jobs {
fmt.Println("worker", id, "processing job", j)
time.Sleep(time.Second)
results <- j * 2
}
}
func main() {
// 為了使用我們的工作池,我們需要發送工作和接受工作的結果,
// 這里我們定義兩個通道,一個jobs,一個results
jobs := make(chan int, 100)
results := make(chan int, 100)
// 這里啟動3個worker協程,一開始的時候worker阻塞執行,因為
// jobs通道里面還沒有工作任務
for w := 1; w <= 3; w++ {
go worker(w, jobs, results)
}
// 這里我們發送9個任務,然后關閉通道,告知任務發送完成
for j := 1; j <= 9; j++ {
jobs <- j
}
close(jobs)
// 然后我們從results里面獲得結果
for a := 1; a <= 9; a++ {
<-results
}
```
運行結果
```
worker 1 processing job 1
worker 2 processing job 2
worker 3 processing job 3
worker 1 processing job 4
worker 3 processing job 5
worker 2 processing job 6
worker 1 processing job 7
worker 3 processing job 8
worker 2 processing job 9
```
- 版權
- 內容
- Go常量
- Go變量
- Go 數值
- Go 數組
- Go 字典
- Go 函數定義
- Go 方法
- Go 結構體
- Go 閉包函數
- Go 接口
- Go 字符串操作函數
- Go 字符串格式化
- Go 自定義排序
- Go Base64編碼
- Go Defer
- Go Exit.md
- Go for循環
- Go if..else if..else 條件判斷
- Go JSON支持
- Go Line Filters
- Go 狀態協程
- Go Panic
- Go range函數
- Go SHA1 散列
- Go String與Byte切片之間的轉換
- Go Switch語句
- Go URL解析
- Go 遍歷通道
- Go 并行功能
- Go 并行通道Channel
- Go 超時
- Go 錯誤處理
- Go 打點器
- Go 遞歸函數
- Go 讀取文件
- Go 工作池
- Go 關閉通道
- Go 函數多返回值
- Go 函數回調
- Go 函數命名返回值
- Go 互斥
- Go 環境變量
- Go 集合功能
- Go 計時器
- Go 進程觸發
- Go 進程執行
- Go hello world
- Go 可變長參數列表
- Go 命令行參數
- Go 命令行參數標記
- Go 排序
- Go 切片
- Go 請求處理頻率控制
- Go 時間
- Go 時間戳
- Go 時間格式化和解析
- Go 數字解析
- Go 隨機數
- Go 通道的同步功能
- Go 通道方向
- Go 通道緩沖
- Go 通道選擇Select
- Go 寫入文件
- Go 信號處理
- Go 原子計數器
- Go 正則表達式
- Go 指針