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