利用Golang寫(xiě)出高并發(fā)代碼的案例

小編給大家分享一下利用Golang寫(xiě)出高并發(fā)代碼的案例，相信大部分人都還不怎么了解，因此分享這篇文章給大家參考一下，希望大家閱讀完這篇文章后大有收獲，下面讓我們一起去了解一下吧！

核心要點(diǎn)

將請(qǐng)求放入隊(duì)列,通過(guò)一定數(shù)量(例如CPU核心數(shù))goroutine組成一個(gè)worker池(pool),workder池中的worker讀取隊(duì)列執(zhí)行任務(wù)

實(shí)例代碼

以下代碼筆者根據(jù)自己的理解進(jìn)行了簡(jiǎn)化,主要是表達(dá)出個(gè)人的思路,實(shí)際后端開(kāi)發(fā)中,根據(jù)實(shí)際場(chǎng)景修改

func doTask() {
 //耗時(shí)炒作(模擬)
 time.Sleep(200 * time.Millisecond)
 wg.Done()
}

//這里模擬的http接口,每次請(qǐng)求抽象為一個(gè)job
func 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 it
func (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()
 }
}

測(cè)試

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()
}

測(cè)試結(jié)果

pkg: golang-study-demo/goroutine
1 2029931652 ns/op
PASS

1w個(gè)任務(wù)放到隊(duì)列中,1000個(gè)worker去執(zhí)行任務(wù),每個(gè)任務(wù)的耗時(shí)200ms,任務(wù)執(zhí)行完需要2s多

以上是“利用Golang寫(xiě)出高并發(fā)代碼的案例”這篇文章的所有內(nèi)容，感謝各位的閱讀！相信大家都有了一定的了解，希望分享的內(nèi)容對(duì)大家有所幫助，如果還想學(xué)習(xí)更多知識(shí)，歡迎關(guān)注億速云行業(yè)資訊頻道！