golang实现队列服务-日常实战总结no.2
队列的概念：队列是一种特殊的线性表，特殊之处在于它只允许在表的前端（front）进行删除操作，而在表的后端（rear）进行插入操作，和栈一样，队列是一种操作受限制的线性表。进行插入操作的端称为队尾，进行删除操作的端称为队头。队列中没有元素时，称为空队列。
用golang实现队列我们需要使用到contain/list这个库。这里提供了push，pop，del的方法。下面我们看一下怎么实现这个队列服务。
list最常用的方式就是新建，新建完了之后是读数据，然后就是到底是从哪个地方开始读，list其实是一个双向链表。下面代码的事例是list的新建以及contain/list库的简单实用：
package main
import (
"container/list"
"fmt"
)
func main() {
l := list.New()
for i := 0; i < 5; i++ {
//这里是从尾部push进去数据
l.PushBack(i)
}
//这里是循环读出list里面的值
for e := l.Front(); e != nil; e = e.Next() {
//这里是读出来
fmt.Print(e.Value)
}
fmt.Println("")
}好了，contain/list的使用我们介绍完了，下面我们来实现一个简单的队列。用list做队列的思路，首先，一头写，一头读，然后读的时候涉及到删除，另外就是涉及到list的加锁问题，这是用list做队列的整理思路。队列：是先进先出。因为contain/list是并发非安全的，所以我们在使用的过程需要考虑锁的问题。
package main
import (
"container/list"
"fmt"
"sync"
)
func main() {
//实例化队列
q := new(Quque)
q.Push("a")
q.Push("b")
q.Push("c")
fmt.Println(q.Pop()) //打印出a
fmt.Println(q.Pop()) //打印出b
fmt.Println(q.Pop()) //打印出c
}
//这个是queue的数据结构，由于contain/list是线程不安全的，需要加锁处理
type Quque struct {
List list.List
Lock sync.Mutex
}
//入
func (this *Quque) Push(a interface{}) {
defer this.Lock.Unlock()
this.Lock.Lock()
this.List.PushFront(a)
}
//出
func (this *Quque) Pop() interface{} {
defer this.Lock.Unlock()
this.Lock.Lock()
e := this.List.Back()
if e != nil {
this.List.Remove(e)
return e.Value
}
return nil
}以上这个代码是一个golang本身单独提供队列服务，如果我们是分布提供队列服务的话，那就要再度延伸使用单独的存储服务来实现。以上的主要提供大家学习。
本文参与 腾讯云自媒体同步曝光计划，分享自微信公众号。
原始发表：2019-11-08，如有侵权请联系 cloudcommunity@tencent.com 删除
评论
登录后参与评论
推荐阅读
腾讯云开发者
