code: func (sq *servingQueue) setThreads(threadCount int) {
  	select {
  	case sq.setThreadsCh <- threadCount:
  	case <-sq.quit:
  		return
  	}
  }
docs: // setThreads sets the allowed processing thread count, suspending tasks as soon as
  // possible if necessary.