[Go语言] 使用golang编写一个并发工作队列

type Worker struct {
  ID    int
  RepJobs chan int64
  SM    *SM
  quit  chan bool
}

type workerPool struct {
  workerChan chan *Worker
  workerList []*Worker
}

func InitWorkerPool() error {
  n := 3
  WorkerPool = &workerPool{
    workerChan: make(chan *Worker, n),
    workerList: make([]*Worker, 0, n),
  }
  for i := 0; i < n; i++ {
    worker := NewWorker(i)
    WorkerPool.workerList = append(WorkerPool.workerList, worker)
    worker.Start()
    log.Debugf("worker %d started", worker.ID)
  }
  return nil
}

func (w *Worker) Start() {
  go func() {
    for {
      WorkerPool.workerChan <- w
      select {
      case jobID := <-w.RepJobs:
        log.Debugf("worker: %d, will handle job: %d", w.ID, jobID)
        w.handleRepJob(jobID)
      case q := <-w.quit:
        if q {
          log.Debugf("worker: %d, will stop.", w.ID)
          return
        }
      }
    }
  }()
}

func Dispatch() {
  for {
    select {
    case job := <-jobQueue:
      go func(jobID int64) {
        println("Trying to dispatch job: %d", jobID)
        worker := <-WorkerPool.workerChan
        worker.RepJobs <- jobID
      }(job)
    }
  }
}

func (w *Worker) Stop() {
  go func() {
    w.quit <- true
  }()
}
func (wp *workerPool) StopJobs(jobs []int64) {
  log.Debugf("Works working on jobs: %v will be stopped", jobs)
  for _, id := range jobs {
    for _, w := range wp.workerList {
      if w.SM.JobID == id {
        log.Debugf("found a worker whose job ID is %d, will try to stop it", id)
        w.SM.Stop(id)
      }
    }
  }
}

int,err:=strconv.Atoi(string)

int64, err := strconv.ParseInt(string, 10, 64)

string:=strconv.Itoa(int)

string:=strconv.FormatInt(int64,10)