func doTask() { //耗時(shí)炒作(模擬) time.Sleep(200 * time.Millisecond) wg.Done()}//這里模擬的http接口,每次請求抽象為一個(gè)jobfunc handle() { //wg.Add(1) job := Job{} JobQueue <- job}var ( MaxWorker = 1000 MaxQueue = 200000 wg  sync.WaitGroup)type Worker struct { quit chan bool}func NewWorker() Worker { return Worker{  quit: make(chan bool)}}// Start method starts the run loop for the worker, listening for a quit channel in// case we need to stop itfunc (w Worker) Start() { go func() {  for {   select {   case <-JobQueue:    // we have received a work request.    doTask()   case <-w.quit:    // we have received a signal to stop    return   }  } }()}// Stop signals the worker to stop listening for work requests.func (w Worker) Stop() { go func() {  w.quit <- true }()}type Job struct {}var JobQueue chan Job = make(chan Job, MaxQueue)type Dispatcher struct {}func NewDispatcher() *Dispatcher { return &Dispatcher{}}func (d *Dispatcher) Run() { // starting n number of workers for i := 0; i < MaxWorker; i++ {  worker := NewWorker()  worker.Start() }}

func Benchmark_handle(b *testing.B) { runtime.GOMAXPROCS(runtime.NumCPU()) d := NewDispatcher() d.Run() for i:=0;i<10000;i++ {  wg.Add(1)  handle() } wg.Wait()}

pkg: golang/70686.html">golang-study-demo/goroutine1 2029931652 ns/opPASS