Versions in this module Expand all Collapse all v1 v1.2.0 May 14, 2024 Changes in this version + const Highest + const Lowest + type PriorityQueue struct + func NewPriorityQueue(numQueues int, ascendingPriority, blocking bool) *PriorityQueue + func (pq *PriorityQueue) Close() + func (pq *PriorityQueue) ReadChan() <-chan interface{} + func (pq *PriorityQueue) ReadValue() (interface{}, bool) + func (pq *PriorityQueue) Write(priority int) chan<- interface{} + func (pq *PriorityQueue) WriteValue(priority int, msg interface{}) bool v1.1.0 Dec 4, 2020