priorityqueue

Documentation

Index

• Variables
• type PriorityQueue
  • func New(n int, l int) *PriorityQueue
  • func (pq *PriorityQueue) Push(x interface{}, p int) error
  • func (pq *PriorityQueue) Run(ctx context.Context, f func(interface{}))

Variables

var (
	ErrContention = errors.New("contention")
)

Types

type PriorityQueue

type PriorityQueue struct {
	Queues []chan interface{}
	// contains filtered or unexported fields
}

PriorityQueue is the basic structure

func New

func New(n int, l int) *PriorityQueue

New is the constructor for PriorityQueue

func (*PriorityQueue) Push

func (pq *PriorityQueue) Push(x interface{}, p int) error

Push pushes an item to the appropriate queue specified in the priority argument if context is given it waits until either the item is pushed or the Context aborts

func (*PriorityQueue) Run

func (pq *PriorityQueue) Run(ctx context.Context, f func(interface{}))

Run is a forever loop popping items from the queues