如何利用Golang写出高并发代码详解

前言

之前一直对golang如何处理高并发http请求的一头雾水,这几天也查了很多相关博客,似懂非懂,不知道具体代码怎么写

下午偶然在开发者头条app上看到一篇国外技术人员的一篇文章用golang处理每分钟百万级请求,看完文章中的代码,自己写了一遍代码,下面自己写下自己的体会

核心要点

将请求放入队列,通过一定数量(例如cpu核心数)goroutine组成一个worker池(pool),workder池中的worker读取队列执行任务

实例代码

以下代码笔者根据自己的理解进行了简化,主要是表达出个人的思路,实际后端开发中,根据实际场景修改

func dotask() {
 //耗时炒作(模拟)
 time.sleep(200 * time.millisecond)
 wg.done()
}

//这里模拟的http接口,每次请求抽象为一个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()
 }
}

测试

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-study-demo/goroutine
1 2029931652 ns/op
pass

1w个任务放到队列中,1000个worker去执行任务,每个任务的耗时200ms,任务执行完需要2s多

以上只是笔者的个人看法,不知道对golang并发编程的理解是否正确,有错误的地方,希望高手指点一二,在此谢过

总结

以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对的支持。