type Task struct {
   // Task方法 任務(wù)
   method func() error
   // 可以擴(kuò)展
}
// NewTask 創(chuàng)建一個(gè)Task
func NewTask(method func() error) *Task {
   return &Task{
      method: method,
   }
}
// Execute 任務(wù)執(zhí)行
func (t *Task) Execute() {
   err := t.method()
   if err != nil {
      panic(err)
   }
}

// 定義一個(gè)協(xié)程池
type Pool struct {
   // 對外的Task入口
   EntryChannel chan *Task
   // 對內(nèi)的Task隊(duì)列
   JobsChannel chan *Task
   // 協(xié)程池的最大work數(shù)量
   WorkerNum int
}
// NewPool 創(chuàng)建Pool的函數(shù)
func NewPool(cap int) *Pool{
   return &Pool{
      EntryChannel: make(chan *Task),
      JobsChannel: make(chan *Task),
      WorkerNum: cap,
   }
}
// 協(xié)程池創(chuàng)建一個(gè)Worker
func (p *Pool)worker(workID int){
   for task:=range p.JobsChannel{
        task.Execute()  //取到任務(wù)就執(zhí)行
      fmt.Println("worker_id 為",workID)
   }
}
// 讓協(xié)程池開始真正的工作
func (p *Pool)run() {
   // 根據(jù)創(chuàng)建協(xié)程池的大小來創(chuàng)建協(xié)程工作
   for i := 0; i < p.WorkerNum; i++ {
      go p.worker(i+1)
   }
   // 不斷遍歷外部的任務(wù)然后丟入到內(nèi)部的隊(duì)列去運(yùn)行
   for task := range p.EntryChannel {
          p.JobsChannel<-task
   }
}

// 主函數(shù) 測試
func main(){
   // 創(chuàng)建一些任務(wù)
   task:=NewTask(PrintTimeNow)
   // 創(chuàng)建協(xié)程池
   pool:=NewPool(4)
   taskNum:=0
   go func(taskNum int) {
      for{
         // 不斷的向池子里寫入任務(wù)task，任務(wù)主要是打印當(dāng)前時(shí)間
         pool.EntryChannel<-task
         // atomic.AddInt32(&taskNum,1)
         taskNum+=1
         fmt.Println("當(dāng)前一共執(zhí)行了",taskNum,"個(gè)任務(wù)")
      }
   }(taskNum)
   pool.run()
}
// 業(yè)務(wù)邏輯
func PrintTimeNow()( err error){
   fmt.Println(time.Now())
   return
}