go 简单多线程处理数据

package main
 
import (
    "fmt"
    // "time"
)
func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        fmt.Println("worker", "processing job", j)
        // time.Sleep(time.Second)
        results <- j
    }
}

func ThreadPool() {
    num := 100
    loopNum := 3
    jobs := make(chan int, num)   //Job为100个可以传递int类型的channel
    results := make(chan int, loopNum)

  //开启三个线程，说明线程池中只有三个线程， 在实际情况下可以动态设置开启线程数量
    for w := 1; w <= loopNum; w++ {
        go worker(w, jobs, results)
    }

  // 添加9个任务
    for j := 1; j <= num; j++ {
        jobs <- j  //向Jobs添加任务： 向Channel中写入数据， 传递的数据类型为int
    }
  //关闭Channel
    close(jobs)

    for a := 1; a <= num; a++ {
        res := <-results  //从Channel中读取数据, 输出的数据类型为 int
        fmt.Println("ID = ", a, "Results = ", res)  //注意 a 与 res 不对应是由于处理器调度的结果
    }
}
 

// 开始执行
func main()  {
    ThreadPool()
}