Go 并发 Worker Pool：最小实现与坑

package main
import (
    "fmt"; "sync"; "time"
)
func main(){
    jobs := make(chan int, 10)
    var wg sync.WaitGroup
    // 启动3个worker
    for i:=0;i<3;i++{
        wg.Add(1)
        go func(id int){
            defer wg.Done()
            for j := range jobs {
                fmt.Printf("worker %d processing %d\n", id, j)
                time.Sleep(100 * time.Millisecond)
            }
        }(i)
    }
    // 生产任务
    for j:=1;j<=10;j++{ jobs <- j }
    close(jobs)
    wg.Wait()
}