pqueue

type DelayQueue[T Delayer] interface {
	Offer(item T)
	ExpiredCh() <-chan T
	Len() int
	Start()
	Stop()
}

type Delayer interface {
	SetExpiration(d int64) bool
	Expiration() int64
}

type LessFunc[T any] func(i, j T) bool

type PriorityQueue[T any] struct {
	// contains filtered or unexported fields
}