package main

import "fmt"

import "time"

//这是我们将要在多个并发实例中支持的任务了。这些执行者将从 jobs 通道接收任务，

//并且通过 results 发送对应的结果。我们将让每个任务间隔 1s 来模仿一个耗时的任务

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() {

    //为了使用 worker 工作池并且收集他们的结果，我们需要2 个通道。

    jobs := make(chan int, 100)

    results := make(chan int, 100)

    //这里启动3个worker，初始是阻塞的，因为还没有传递任务。

    for i:=1; i<=3; i++{

        go worker(i, jobs, results)

    }

    //这里发送9个jobs,并且close关闭通道。代表所有任务

    for j:=1; j<=9; j++{

        jobs <- j

    }

    close(jobs)

    //最后，我们收集所有这些任务的返回值。results

    for a:=1; a<=9; a++{

        <- results

    }

}

$ go run example.go

worker 3 processing job 1

worker 1 processing job 2

worker 2 processing job 3

worker 3 processing job 4

worker 2 processing job 5

worker 1 processing job 6

worker 3 processing job 7

worker 1 processing job 8

worker 2 processing job 9