Golang 높은 동시성 코드 공유

오늘 리더가 Golang을 사용하는 이유를 물었습니다. 동료는 구문이 간단하고 언어가 새롭으며 높은 동시성을 지원한다고 대답했습니다. 높은 동시성을 달성하는 방법은? 다음 기사에서는 Golang을 사용하여 높은 동시성 코드를 작성하는 방법에 대한 관련 정보를 주로 소개합니다. 필요한 친구들은 참고할 수 있습니다. . 술집.

머리말

저는 Golang이 높은 동시 http 요청을 처리하는 방법에 대해 항상 혼란스러워했습니다. 지난 며칠 동안 많은 관련 블로그를 확인했지만 이해한 것 같지만 구체적인 내용을 어떻게 작성해야 할지 모르겠습니다. code

오후 우연히 개발자 Toutiao APP에서 Golang을 사용하여 분당 수백만 건의 요청을 처리하는 기사를 보았습니다. 기사의 코드를 읽은 후 아래에 직접 코드를 작성하겠습니다.

코어 포인트

요청을 대기열에 넣고 특정 수(예: CPU 코어 수) 고루틴을 통해 작업자 풀(풀)을 구성하고 작업자 풀에 있는 작업자가 대기열을 읽습니다. 작업 실행

예제 코드

다음 코드는 작성자의 이해를 바탕으로 단순화되었으며, 주로 실제 백엔드 개발 시 개인적인 아이디어를 표현하기 위해 수정되었습니다. 실제 시나리오

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

Test

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명의 작업자가 작업을 실행하고 각 작업에 200ms가 걸리며 작업을 완료하는 데 2초 이상이 걸립니다

The 위 내용은 작성자의 개인적인 의견일 뿐입니다. 제가 Golang 동시 프로그래밍에 대해 이해한 것이 맞는지, 아니면 혹시 실수가 있는지는 잘 모르겠습니다. 전문가의 조언을 부탁드립니다. 감사합니다

위 내용은 Golang 높은 동시성 코드 공유의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!