如何利用Golang写出高并发代码详解_用go高并发测试api - CSDN文库

133 浏览量更新于2023-03-03 评论收藏 51KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

如何利用如何利用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

}()

}

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余1页未读，立即下载

评论0

weixin_38645266

粉丝: 4
资源: 948

会员权益专享

图片转文字

全年可省5，000元立即开通

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈