Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type TimePriorityQueue ¶
type TimePriorityQueue[T any] struct { // contains filtered or unexported fields }
TimePriorityQueue is a priority queue that dequeues elements at (or after) a specified time, and prioritizes elements based on a priority value. It is safe for concurrent use.
func NewTimePriorityQueue ¶
func NewTimePriorityQueue[T any]() *TimePriorityQueue[T]
func (*TimePriorityQueue[T]) Dequeue ¶
func (t *TimePriorityQueue[T]) Dequeue(ctx context.Context) T
func (*TimePriorityQueue[T]) Enqueue ¶
func (t *TimePriorityQueue[T]) Enqueue(at time.Time, priority int, v T)
func (*TimePriorityQueue[T]) Len ¶
func (t *TimePriorityQueue[T]) Len() int
func (*TimePriorityQueue[T]) Peek ¶
func (t *TimePriorityQueue[T]) Peek() T
func (*TimePriorityQueue[T]) Reset ¶
func (t *TimePriorityQueue[T]) Reset() []T
type TimeQueue ¶
type TimeQueue[T any] struct { // contains filtered or unexported fields }
TimeQueue is a priority queue that dequeues elements at (or after) a specified time. It is safe for concurrent use.
func NewTimeQueue ¶
Source Files
Click to show internal directories.
Click to hide internal directories.