queue

Aug 4, 2015

Changes in this version

+ var ErrDisposed = errors.New(`queue: disposed`)

+ var ErrTimeout = errors.New(`queue: poll timed out`)

+ func ExecuteInParallel(q *Queue, fn func(interface{}))

+ type Item interface

+ Compare func(other Item) int

+ type PriorityQueue struct

+ func NewPriorityQueue(hint int, allowDuplicates bool) *PriorityQueue

+ func (pq *PriorityQueue) Dispose()

+ func (pq *PriorityQueue) Disposed() bool

+ func (pq *PriorityQueue) Empty() bool

+ func (pq *PriorityQueue) Get(number int) ([]Item, error)

+ func (pq *PriorityQueue) Len() int

+ func (pq *PriorityQueue) Peek() Item

+ func (pq *PriorityQueue) Put(items ...Item) error

+ type Queue struct

+ func New(hint int64) *Queue

+ func (q *Queue) Dispose() []interface{}

+ func (q *Queue) Disposed() bool

+ func (q *Queue) Empty() bool

+ func (q *Queue) Get(number int64) ([]interface{}, error)

+ func (q *Queue) Len() int64

+ func (q *Queue) Poll(number int64, timeout time.Duration) ([]interface{}, error)

+ func (q *Queue) Put(items ...interface{}) error

+ func (q *Queue) TakeUntil(checker func(item interface{}) bool) ([]interface{}, error)

+ type RingBuffer struct

+ func NewRingBuffer(size uint64) *RingBuffer

+ func (rb *RingBuffer) Cap() uint64

+ func (rb *RingBuffer) Dispose()

+ func (rb *RingBuffer) Get() (interface{}, error)

+ func (rb *RingBuffer) IsDisposed() bool

+ func (rb *RingBuffer) Len() uint64

+ func (rb *RingBuffer) Offer(item interface{}) (bool, error)

+ func (rb *RingBuffer) Put(item interface{}) error