Help us shape the future of Go! Take the 2026 Go Developer Survey

Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
- API
  
  Reference documentation for the pkg.go.dev API
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

priorityq

package module

Go to main page

Versions in this module

v1

v1.0.0

Feb 15, 2018

Changes in this version

+ const PARALLELISM_COEFF

+ type ParallelQ struct

+ func (q ParallelQ) BlockUntilNoPending()

+ func (q ParallelQ) Dequeue() (PriorityScorer, PriorityQ)

+ func (q ParallelQ) Enqueue(priority PriorityScorer) PriorityQ

+ func (q ParallelQ) IsEmpty() bool

+ func (q ParallelQ) Length() int

+ func (q ParallelQ) Meld(otherQ PriorityQ) PriorityQ

+ func (q ParallelQ) Peek() PriorityScorer

+ type PriorityQ interface

+ Dequeue func() (PriorityScorer, PriorityQ)

+ Enqueue func(priority PriorityScorer) PriorityQ

+ IsEmpty func() bool

+ Length func() int

+ Meld func(otherQ PriorityQ) PriorityQ

+ Peek func() PriorityScorer

+ func NewImmutableSynchronousQ() PriorityQ

+ func NewMutableParallelQ() PriorityQ

+ type PriorityScorer interface

+ Score func() int

+ type SynchronousQ struct

+ func (b SynchronousQ) DequeueWithMergeCallback(mergeCallback func([]node, ...*skewBinomial) skewBinomial) (PriorityScorer, bootstrappedSkewBinomial)

+ func (b SynchronousQ) IsEmpty() bool

+ func (b SynchronousQ) Length() int

+ func (b SynchronousQ) Peek() PriorityScorer

+ func (b SynchronousQ) Score() int

+ func (b SynchronousQ) String() string

+ func (s SynchronousQ) Dequeue() (PriorityScorer, PriorityQ)

+ func (s SynchronousQ) Enqueue(priority PriorityScorer) PriorityQ

+ func (s SynchronousQ) Meld(otherQ PriorityQ) PriorityQ

v0

v0.1.0

Feb 13, 2018

Changes in this version

+ const MELD_PERIOD

+ var FAIL_ADDRESS unsafe.Pointer = unsafe.Pointer(new(int8))

+ var NULL_OBJECT = NullObject

+ func MaxParallelism() int

+ type BootstrappedSkewBinomialQueue struct

+ func NewEmptyBootstrappedSkewBinomialQueue() BootstrappedSkewBinomialQueue

+ func (b BootstrappedSkewBinomialQueue) Dequeue() (QueuePriority, BootstrappedSkewBinomialQueue)

+ func (b BootstrappedSkewBinomialQueue) DequeueWithMergeCallback(mergeCallback func([]Node, ...*SkewBinomialQueue) SkewBinomialQueue) (QueuePriority, BootstrappedSkewBinomialQueue)

+ func (b BootstrappedSkewBinomialQueue) Enqueue(priority QueuePriority) BootstrappedSkewBinomialQueue

+ func (b BootstrappedSkewBinomialQueue) IsEmpty() bool

+ func (b BootstrappedSkewBinomialQueue) Length() int

+ func (b BootstrappedSkewBinomialQueue) LessThan(otherPriority QueuePriority) bool

+ func (b BootstrappedSkewBinomialQueue) Meld(otherQ BootstrappedSkewBinomialQueue) BootstrappedSkewBinomialQueue

+ func (b BootstrappedSkewBinomialQueue) Peek() QueuePriority

+ func (b BootstrappedSkewBinomialQueue) String() string

+ type LazyMergeSkewBinomialQueue struct

+ func (q LazyMergeSkewBinomialQueue) BlockUntilNoPending()

+ func (q LazyMergeSkewBinomialQueue) Dequeue() (QueuePriority, PriorityQueue)

+ func (q LazyMergeSkewBinomialQueue) Enqueue(priority QueuePriority) PriorityQueue

+ func (q LazyMergeSkewBinomialQueue) IsEmpty() bool

+ func (q LazyMergeSkewBinomialQueue) Length() int

+ func (q LazyMergeSkewBinomialQueue) Meld(otherQ PriorityQueue) PriorityQueue

+ func (q LazyMergeSkewBinomialQueue) Peek() QueuePriority

+ type Node interface

+ Children func() []Node

+ IsEmpty func() bool

+ Length func() int

+ Link func(heaps ...Node) Node

+ Peek func() QueuePriority

+ Rank func() int

+ func NewSkewBinomialHeap(priority QueuePriority) Node

+ type NullObject struct

+ func (n NullObject) Children() []Node

+ func (n NullObject) IsEmpty() bool

+ func (n NullObject) Length() int

+ func (n NullObject) Link(heaps ...Node) Node

+ func (n NullObject) Peek() QueuePriority

+ func (n NullObject) Rank() int

+ type PriorityQueue interface

+ Dequeue func() (QueuePriority, PriorityQueue)

+ Enqueue func(priority QueuePriority) PriorityQueue

+ IsEmpty func() bool

+ Length func() int

+ Meld func(otherQ PriorityQueue) PriorityQueue

+ Peek func() QueuePriority

+ func NewEmptyLazyMergeSkewBinomialQueue() PriorityQueue

+ type QueuePriority interface

+ LessThan func(otherPriority QueuePriority) bool

+ type RootedSkewBinomialQueue struct

+ func NewEmptyRootedSkewBinomialQueue() RootedSkewBinomialQueue

+ func (r RootedSkewBinomialQueue) Dequeue() (QueuePriority, RootedSkewBinomialQueue)

+ func (r RootedSkewBinomialQueue) Enqueue(priority QueuePriority) RootedSkewBinomialQueue

+ func (r RootedSkewBinomialQueue) IsEmpty() bool

+ func (r RootedSkewBinomialQueue) Length() int

+ func (r RootedSkewBinomialQueue) Meld(otherQ RootedSkewBinomialQueue) RootedSkewBinomialQueue

+ func (r RootedSkewBinomialQueue) Peek() QueuePriority

+ type SkewBinomialHeap struct

+ func (s SkewBinomialHeap) Children() []Node

+ func (s SkewBinomialHeap) IsEmpty() bool

+ func (s SkewBinomialHeap) Length() int

+ func (s SkewBinomialHeap) Link(heaps ...Node) Node

+ func (s SkewBinomialHeap) Peek() QueuePriority

+ func (s SkewBinomialHeap) Rank() int

+ type SkewBinomialQueue struct

+ func NewEmptySkewBinomialQueue() SkewBinomialQueue

+ func (q SkewBinomialQueue) Dequeue() (QueuePriority, PriorityQueue)

+ func (q SkewBinomialQueue) DequeueWithMergeCallback(callback func([]Node, ...*SkewBinomialQueue) SkewBinomialQueue) (QueuePriority, PriorityQueue)

+ func (q SkewBinomialQueue) Enqueue(priority QueuePriority) PriorityQueue

+ func (q SkewBinomialQueue) IsEmpty() bool

+ func (q SkewBinomialQueue) Length() int

+ func (q SkewBinomialQueue) Meld(otherQ PriorityQueue) PriorityQueue

+ func (q SkewBinomialQueue) Peek() QueuePriority

+ func (q SkewBinomialQueue) String() string

+ type ThreadSafeList struct

+ func NewThreadSafeList() ThreadSafeList

+ func (t *ThreadSafeList) DeleteObject(object unsafe.Pointer) (success bool)

+ func (t *ThreadSafeList) InsertObject(object unsafe.Pointer, lessThanFn func(unsafe.Pointer, unsafe.Pointer) bool)

+ func (t *ThreadSafeList) PopFirst(failAddress unsafe.Pointer) unsafe.Pointer

+ func (t *ThreadSafeList) PopHead() unsafe.Pointer

+ func (t ThreadSafeList) Count() int

+ func (t ThreadSafeList) Iter() <-chan unsafe.Pointer

+ func (t ThreadSafeList) LengthGreaterThan(n int) bool

+ func (t ThreadSafeList) Peek() unsafe.Pointer

+ func (t ThreadSafeList) PopNth(n int, failAddress unsafe.Pointer) unsafe.Pointer

+ type TrySplitParameter struct

+ N int

Incompatible versions in this module

v2.0.0+incompatible

May 15, 2018

Other modules containing this package

github.com/slobdell/skew-binomial-queues/v3

github.com/slobdell/skew-binomial-queues/v4