delayqueue

Documentation

Index

• type DelayQueue
  • func NewDelayQueue[T Delayed](cmp comparator.Comparable[T]) *DelayQueue[T]
  • func (dq *DelayQueue[T]) Add(val T)
  • func (dq *DelayQueue[T]) Take(quit <-chan struct{}) (val T, exit bool)
  • func (dq *DelayQueue[T]) TimeUnit(timeUnit time.Duration) *DelayQueue[T]
• type Delayed

Types

type DelayQueue

type DelayQueue[T Delayed] struct {
	// contains filtered or unexported fields
}

DelayQueue delay queue

func NewDelayQueue

func NewDelayQueue[T Delayed](cmp comparator.Comparable[T]) *DelayQueue[T]

NewDelayQueue new delay queue instance.

func (*DelayQueue[T]) Add

func (dq *DelayQueue[T]) Add(val T)

Add to queue

func (*DelayQueue[T]) Take

func (dq *DelayQueue[T]) Take(quit <-chan struct{}) (val T, exit bool)

Take from queue.

func (*DelayQueue[T]) TimeUnit

func (dq *DelayQueue[T]) TimeUnit(timeUnit time.Duration) *DelayQueue[T]

TimeUnit set time unit.

type Delayed

type Delayed interface {
	Delay() int64
	comparable
}