Method Len

internal/queue/timepriorityqueue.go:22–26

()

}

func (t *TimePriorityQueue[T]) Len() int {
	t.tqueue.mu.Lock()
	defer t.tqueue.mu.Unlock()
	return t.tqueue.heap.Len() + t.ready.Len()
}

func (t *TimePriorityQueue[T]) Peek() T {
	t.tqueue.mu.Lock()