可以直接拿去当成一个库来用

举例

package mainimport "your/path/to/.../Concurrence"//定义一个实现Job接口的数据type Score struct {    Num int}//定义对数据的处理func (s *Score) Do() {    fmt.Println("num:", s.Num)    time.Sleep(1 * 1 * time.Second)}func main() {    num := 100 * 100 * 20    // debug.SetMaxThreads(num + 1000) //设置最大线程数    // 注册工作池，传入任务    // 参数1 worker并发个数    p := NewWorkerPool(num)    p.Run()    //写入一亿条数据    datanum := 100 * 100 * 100 * 100    go func() {        for i := 1; i <= datanum; i++ {            sc := &Score{Num: i}            p.JobQueue <- sc //数据传进去会被自动执行Do()方法，具体对数据的处理自己在Do()方法中定义        }    }()//循环打印输出当前进程的Goroutine 个数    for {        fmt.Println("runtime.NumGoroutine() :", runtime.NumGoroutine())        time.Sleep(2 * time.Second)    }}

Concurrence.go

package Concurrenceimport "fmt"// --------------------------- Job ---------------------type Job interface {    Do()}// --------------------------- Worker ---------------------type Worker struct {    JobQueue chan Job}func NewWorker() Worker {    return Worker{JobQueue: make(chan Job)}}func (w Worker) Run(wq chan chan Job) {    go func() {        for {            wq <- w.JobQueue            select {            case job := <-w.JobQueue:                job.Do()            }        }    }()}// --------------------------- WorkerPool ---------------------type WorkerPool struct {    workerlen   int    JobQueue    chan Job    WorkerQueue chan chan Job}func NewWorkerPool(workerlen int) *WorkerPool {    return &WorkerPool{        workerlen:   workerlen,        JobQueue:    make(chan Job),        WorkerQueue: make(chan chan Job, workerlen),    }}func (wp *WorkerPool) Run() {    fmt.Println("初始化worker")    //初始化worker    for i := 0; i < wp.workerlen; i++ {        worker := NewWorker()        worker.Run(wp.WorkerQueue)    }    // 循环获取可用的worker,往worker中写job    go func() {        for {            select {            case job := <-wp.JobQueue:                worker := <-wp.WorkerQueue                worker <- job            }        }    }()}// --------------- 使用 --------------------/*type Score struct {    Num int}func (s *Score) Do() {    fmt.Println("num:", s.Num)    time.Sleep(1 * 1 * time.Second)}func main() {    num := 100 * 100 * 20    // debug.SetMaxThreads(num + 1000) //设置最大线程数    // 注册工作池，传入任务    // 参数1 worker并发个数    p := NewWorkerPool(num)    p.Run()    datanum := 100 * 100 * 100 * 100    go func() {        for i := 1; i <= datanum; i++ {            sc := &Score{Num: i}            p.JobQueue <- sc        }    }()    for {        fmt.Println("runtime.NumGoroutine() :", runtime.NumGoroutine())        time.Sleep(2 * time.Second)    }}*/