Documentation
¶
Overview ¶
Package pool 无锁消息池，多读多写, 用于goroutine 间收发消息
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Pool ¶
type Pool struct {
// contains filtered or unexported fields
}
Pool None lock Message pool
type SerialReadPool ¶
type SerialReadPool struct {
// contains filtered or unexported fields
}
SerialReadPool 无锁消息池，多写,有序单读(按写入时间排序)。适用于多个消息发送者,单个消息接收者模式
func (*SerialReadPool) ForEach ¶
func (p *SerialReadPool) ForEach(cb func(v interface{}))
ForEach Peek messages
func (*SerialReadPool) Init ¶
func (p *SerialReadPool) Init() *SerialReadPool
Init : init SerialReadPool
Source Files
Click to show internal directories.
Click to hide internal directories.