goring

Documentation

Index

• type Queue
  • func New(initialSize int64) *Queue
  • func (q *Queue) Empty() bool
  • func (q *Queue) Length() int64
  • func (q *Queue) Pop() (interface{}, bool)
  • func (q *Queue) PopMany(count int64) ([]interface{}, bool)
  • func (q *Queue) Push(item interface{})

Types

type Queue

type Queue struct {
	// contains filtered or unexported fields
}

func New

func New(initialSize int64) *Queue

func (*Queue) Empty

func (q *Queue) Empty() bool

func (*Queue) Length

func (q *Queue) Length() int64

func (*Queue) Pop

func (q *Queue) Pop() (interface{}, bool)

single consumer

func (*Queue) PopMany

func (q *Queue) PopMany(count int64) ([]interface{}, bool)

func (*Queue) Push

func (q *Queue) Push(item interface{})

满了就扩容为原来的2倍大小，有点像redis hash存储，不过它是渐近式扩容，这是一次性扩容到位。