[Go小技巧] 实现Go经典的消息队列处理协程

发布时间：2020-12-16 18:27:24 所属栏目：大数据来源：网络整理

导读：type Engine struct {queue chan interface{}}// 推送请求到队列func (e *Engine) Push(req interface{}) {e.queue - req}// 开启服务协程func (e *Engine) Serve() {go func() {for {req := -e.queue// do some thing_ = req}}()}

type Engine struct {
	queue chan interface{}
}

// 推送请求到队列
func (e *Engine) Push(req interface{}) {
	e.queue <- req
}

// 开启服务协程
func (e *Engine) Serve() {
	go func() {
		for {
			req := <-e.queue
			// do some thing
			_ = req
		}
	}()
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!