queue

Documentation

Overview

bill 2018.1.8 优先级队列[同级别先进先出]权重值越大越优先

Index

• type CircularLinked
  • func (q *CircularLinked) Dump()
  • func (q *CircularLinked) Front() *list.Element
  • func (q *CircularLinked) Len() int
  • func (q *CircularLinked) Pop() interface{}
  • func (q *CircularLinked) Push(v interface{})
  • func (q *CircularLinked) Remove(iter *list.Element)
• type Item
• type PriorityQueue
  • func NewPriorityQueue() *PriorityQueue
  • func (pq *PriorityQueue) Clear()
  • func (pq *PriorityQueue) Dump()
  • func (pq *PriorityQueue) Expirations(expriCallback func(item *Item))
  • func (pq *PriorityQueue) Len() int
  • func (pq *PriorityQueue) Pop() *Item
  • func (pq *PriorityQueue) Push(v *Item)

Types

type CircularLinked

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

func (*CircularLinked) Dump

func (q *CircularLinked) Dump()

func (*CircularLinked) Front

func (q *CircularLinked) Front() *list.Element

读取第一个元素后,把它移到队列尾

func (*CircularLinked) Len

func (q *CircularLinked) Len() int

func (*CircularLinked) Pop

func (q *CircularLinked) Pop() interface{}

func (*CircularLinked) Push

func (q *CircularLinked) Push(v interface{})

func (*CircularLinked) Remove

func (q *CircularLinked) Remove(iter *list.Element)

移除元素

type Item

type Item struct {
	Data       interface{} //数据
	Priority   int32       //优先级
	AddTime    time.Time   //插入队列的时间
	Expiration int64       //过期时间值 以秒为单位
}

type PriorityQueue

type PriorityQueue struct {
	Data        *list.List
	PriorityMap map[int32]*pqmap
}

func NewPriorityQueue

func NewPriorityQueue() *PriorityQueue

func (*PriorityQueue) Clear

func (pq *PriorityQueue) Clear()

清除队列

func (*PriorityQueue) Dump

func (pq *PriorityQueue) Dump()

func (*PriorityQueue) Expirations

func (pq *PriorityQueue) Expirations(expriCallback func(item *Item))

检测超时任务

func (*PriorityQueue) Len

func (pq *PriorityQueue) Len() int

func (*PriorityQueue) Pop

func (pq *PriorityQueue) Pop() *Item

func (*PriorityQueue) Push

func (pq *PriorityQueue) Push(v *Item)