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

pq

package module

Go to main page

Versions in this module

v0

v0.2.1

Aug 6, 2026

Changes in this version

type PriorityChannel

+ func (pc *PriorityChannel[T]) Close() error

+ func (pc *PriorityChannel[T]) Len() int

v0.2.0

Aug 1, 2026

v0.1.6

Jul 29, 2026

v0.1.5

Jul 29, 2026

v0.1.4

Jul 29, 2026

Changes in this version

type PriorityChannel

+ func (pc *PriorityChannel[T]) PopBlockingWithCancel(ctx context.Context) (T, int, error)

v0.1.3

Jul 29, 2026

Changes in this version

type PriorityChannel

+ func (pc *PriorityChannel[T]) PopBlocking() (T, int)

type PriorityQueue

+ func (pq *PriorityQueue[C, T]) Len() int

v0.1.2

Jul 27, 2026

Changes in this version

type PriorityChannel

+ func (pc *PriorityChannel[T]) PopWithCancel(ctx context.Context) (T, int, bool, error)

v0.1.1

Jul 17, 2026

v0.1.0

Jul 13, 2026

Changes in this version

+ type ChannelMessage struct

+ Payload T

+ Priority int

+ type Comparator = func(a, b T) int

+ type PriorityChannel struct

+ func NewPriorityChannel[T any]() *PriorityChannel[T]

+ func (pc *PriorityChannel[T]) Pop() (T, int, bool)

+ func (pc *PriorityChannel[T]) Push(item T, priority int)

+ func (pc *PriorityChannel[T]) TryImmediatePop() (T, int, bool)

+ type PriorityQueue struct

+ func NewPriorityQueue[C Comparator[T], T any](cmp C) *PriorityQueue[C, T]

+ func (pq *PriorityQueue[C, T]) Peek() (T, bool)

+ func (pq *PriorityQueue[C, T]) Pop() (T, bool)

+ func (pq *PriorityQueue[C, T]) Push(item T)