如何利用Golang写出高并发代码详解
前言
之前一直对Golang如何处理高并发http请求的一头雾水,这几天也查了很多相关博客,似懂非懂,不知道具体代码怎么写
下午偶然在开发者头条APP上看到一篇国外技术人员的一篇文章用Golang处理每分钟百万级请求,看完文章中的代码,自己写了一遍代码,下面自己写下自己的体会
核心要点
将请求放入队列,通过一定数量(例如CPU核心数)goroutine组成一个worker池(pool),workder池中的worker读取队列执行任务
实例代码
以下代码笔者根据自己的理解进行了简化,主要是表达出个人的思路,实际后端开发中,根据实际场景修改
funcdoTask(){
//耗时炒作(模拟)
time.Sleep(200*time.Millisecond)
wg.Done()
}
//这里模拟的http接口,每次请求抽象为一个job
funchandle(){
//wg.Add(1)
job:=Job{}
JobQueue<-job
}
var(
MaxWorker=1000
MaxQueue=200000
wgsync.WaitGroup
)
typeWorkerstruct{
quitchanbool
}
funcNewWorker()Worker{
returnWorker{
quit:make(chanbool)}
}
//Startmethodstartstherunloopfortheworker,listeningforaquitchannelin
//caseweneedtostopit
func(wWorker)Start(){
gofunc(){
for{
select{
case<-JobQueue:
//wehavereceivedaworkrequest.
doTask()
case<-w.quit:
//wehavereceivedasignaltostop
return
}
}
}()
}
//Stopsignalstheworkertostoplisteningforworkrequests.
func(wWorker)Stop(){
gofunc(){
w.quit<-true
}()
}
typeJobstruct{
}
varJobQueuechanJob=make(chanJob,MaxQueue)
typeDispatcherstruct{
}
funcNewDispatcher()*Dispatcher{
return&Dispatcher{}
}
func(d*Dispatcher)Run(){
//startingnnumberofworkers
fori:=0;i
测试
funcBenchmark_handle(b*testing.B){
runtime.GOMAXPROCS(runtime.NumCPU())
d:=NewDispatcher()
d.Run()
fori:=0;i<10000;i++{
wg.Add(1)
handle()
}
wg.Wait()
}
测试结果
pkg:golang-study-demo/goroutine
12029931652ns/op
PASS
1w个任务放到队列中,1000个worker去执行任务,每个任务的耗时200ms,任务执行完需要2s多
以上只是笔者的个人看法,不知道对Golang并发编程的理解是否正确,有错误的地方,希望高手指点一二,在此谢过
总结
以上就是这篇文章的全部内容了，希望本文的内容对大家的学习或者工作能带来一定的帮助，如果有疑问大家可以留言交流，谢谢大家对毛票票的支持。