prque

Documentation

Overview

Example (Usage)

Insert some data into a priority queue and pop them out in prioritized order.

package main

import (
	"fmt"

	"github.com/fractalplatform/fractal/common/prque"
)

func main() {
	// Define some data to push into the priority queue
	prio := []int64{77, 22, 44, 55, 11, 88, 33, 99, 0, 66}
	data := []string{"zero", "one", "two", "three", "four", "five", "six", "seven", "eight", "nine"}

	// Create the priority queue and insert the prioritized data
	pq := prque.New(nil)
	for i := 0; i < len(data); i++ {
		pq.Push(data[i], prio[i])
	}
	// Pop out the data and print them
	for !pq.Empty() {
		val, prio := pq.Pop()
		fmt.Printf("%d:%s ", prio, val)
	}
}

Output:

99:seven 88:five 77:zero 66:nine 55:three 44:two 33:six 22:one 11:four 0:eight

Index

• type Prque
  • func New(setIndex setIndexCallback) *Prque
  • func (p *Prque) Empty() bool
  • func (p *Prque) Pop() (interface{}, int64)
  • func (p *Prque) PopItem() interface{}
  • func (p *Prque) Push(data interface{}, priority int64)
  • func (p *Prque) Remove(i int) interface{}
  • func (p *Prque) Reset()
  • func (p *Prque) Size() int

Examples

• Package (Usage)

Types

type Prque

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

Priority queue data structure.

func New

func New(setIndex setIndexCallback) *Prque

Creates a new priority queue.

func (*Prque) Empty

func (p *Prque) Empty() bool

Checks whether the priority queue is empty.

func (*Prque) Pop

func (p *Prque) Pop() (interface{}, int64)

Pops the value with the greates priority off the stack and returns it. Currently no shrinking is done.

func (*Prque) PopItem

func (p *Prque) PopItem() interface{}

Pops only the item from the queue, dropping the associated priority value.

func (*Prque) Push

func (p *Prque) Push(data interface{}, priority int64)

Pushes a value with a given priority into the queue, expanding if necessary.

func (*Prque) Remove

func (p *Prque) Remove(i int) interface{}

Remove removes the element with the given index.

func (*Prque) Reset

func (p *Prque) Reset()

Clears the contents of the priority queue.

func (*Prque) Size

func (p *Prque) Size() int

Returns the number of element in the priority queue.