<9> go worker线程池

Worker Pools

package main
import "fmt"
import "time"
// 使用goroutine 开启大小为3的线程池
// 其中1个channel为执行做通信,1个对结果进行保存
// 创建的worker
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() {
 // 创建channel
 jobs := make(chan int, 100)
 results := make(chan int, 100)
 // 3个worker作为一个pool
 for w := 1; w <= 3; w++ {
 go worker(w, jobs, results)
 }
 // 发送9个jobs,然后关闭
 for j := 1; j <= 9; j++ {
 jobs <- j
 }
 close(jobs)
 // 最后收集结果
 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 2 processing job 5
worker 3 processing job 6
worker 1 processing job 7
worker 2 processing job 8
worker 3 processing job 9
real 0m3.149s

有疑问加站长微信联系(非本文作者)

• 请尽量让自己的回复能够对别人有帮助
• 支持 Markdown 格式, **粗体**、~~删除线~~、`单行代码`
• 支持 @ 本站用户;支持表情(输入 : 提示),见 Emoji cheat sheet
• 图片支持拖拽、截图粘贴等方式上传