最近需要使用到一个Queue队列, 并发写入的.
作为gopher, 第一个马上想到的是channel, channel用起来是很爽, 并发安全, 直接一端取, 一端塞, 非常和谐友好. 但是, channel不支持动态扩容啊, 当一个channel满了之后, 想要扩容, 只能make一个新的, 然后做一个迁移, 这会卡住好长时间, 业务需求不满足.
然后找到了container/list这个包, 有个list结构体, 使用简单, 接口清晰, 代码实现也简单, 用着也挺舒服的. 就是不是并发安全的, 只能自己动手包了一层并发的皮:import ( "container/list"
"sync")
type Queue struct {
l *list.List
m sync.Mutex
}func NewQueue() *Queue { return &Queue{l: list.New()}
}
func (q *Queue) PushBack(v interface{}) { if v == nil { return
}
q.m.Lock()
defer q.m.Unlock()
q.l.PushBack(v)
}
func (q *Queue) Front() *list.Element {
q.m.Lock()
defer q.m.Unlock() return q.l.Front()
}
func (q *Queue) Remove(e *list.Element) { if e == nil { return
}
q.m.Lock()
defer q.m.Unlock()
q.l.Remove(e)
}
func (q *Queue) Len() int {
q.m.Lock()
defer q.m.Unlock() return q.l.Len()
}
这样就基本满足了.
使用过程中, 发现list有个小坑: 遍历的时候不能Removefor e := l.Front(); e != nil; e = e.Next {
l.Remove(e)
}
按照设想, 这应该会移除list里所有的元素, 但是, 结果是只移除了第一个. 原因是: Remove时候, e.next = nil, 使得for判断中, e != nil不成立了, 所以退出了循环.
这时候有两种解决办法:var next *list.Elementfor e := l.Front(); e != nil; e = next { next = e.Next()
l.Remove(e)
}for { e := l.Front()
if e == nil {
break
} l.Remove(e)
}
that's all
作者：Lucas_Ye
链接：https://www.jianshu.com/p/dfd6e5779f4b
