queue

Mar 24, 2020

Changes in this version

+ type CircularBuffer struct

+ func NewCircularBuffer(size int) (*CircularBuffer, error)

+ func (c *CircularBuffer) Add(item interface{})

+ func (c *CircularBuffer) Latest() interface{}

+ func (c *CircularBuffer) List() []interface{}

+ func (c *CircularBuffer) Total() int

Dec 12, 2019

Changes in this version

+ type PriorityQueue struct

+ func (pq *PriorityQueue) Empty() bool

+ func (pq *PriorityQueue) Len() int

+ func (pq *PriorityQueue) Pop() PriorityQueueItem

+ func (pq *PriorityQueue) Push(item PriorityQueueItem)

+ func (pq *PriorityQueue) Top() PriorityQueueItem

+ type PriorityQueueItem interface

+ Less func(other PriorityQueueItem) bool

Feb 7, 2019

Changes in this version

+ type ConcurrentQueue struct

+ func NewConcurrentQueue(bufferSize int) *ConcurrentQueue

+ func (cq *ConcurrentQueue) ChanIn() chan<- interface{}

+ func (cq *ConcurrentQueue) ChanOut() <-chan interface{}

+ func (cq *ConcurrentQueue) Start()

+ func (cq *ConcurrentQueue) Stop()

+ type GCQueue struct

+ func NewGCQueue(newItem func() Recycler, returnQueueSize int, ...) *GCQueue

+ func (q *GCQueue) Return(item Recycler)

+ func (q *GCQueue) Take() Recycler

+ type Recycler interface

+ Recycle func()