本文共 2176 字，大约阅读时间需要 7 分钟。

main.go

package mainimport (   "fmt"   conc "github.com/micro/examples/Test/Concurrence"   "runtime"   //"runtime"   "time")//定义一个实现Job接口的数据type Score struct {   Num int}//定义对数据的处理func (s *Score) Do() {   fmt.Println("num:", s.Num)   //time.Sleep(1 * 1 * time.Second)}func main() {   start := time.Now()   //some func or operation   num := 100 *100*20   // debug.SetMaxThreads(num + 1000) //设置最大线程数   // 注册工作池，传入任务   // 参数1 worker并发个数   p := conc.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()方法中定义      }   }()   cost := time.Since(start)   fmt.Printf("cost=[%s]",cost)   //循环打印输出当前进程的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:            //fmt.Println("job.do....")            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:            fmt.Println("循环获取可用的worker,往worker中写job")            worker := <-wp.WorkerQueue            worker <- job         }      }   }()}

转载地址：http://ikwsi.baihongyu.com/