prioritywaitqueue

Dec 17, 2025

Changes in this version

+ type Chooser func(waiters []T) int

+ type Option func(PriorityWaitQueue[T])

+ func WithClock[T interface{}](clock clock.Clock) Option[T]

+ func WithInitialPause[T interface{}](duration time.Duration) Option[T]

+ type PriorityWaitQueue interface

+ InitialPauseDone func(block bool) bool

+ Wait func(waitWith T) func()

+ func New[T interface{}](choose Chooser[T], options ...Option[T]) PriorityWaitQueue[T]