# 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 指针