delayqueue

README

delay-queue

Documentation

Index

• type Entry
• type HandleFun
• type LinkList
  • func (ll *LinkList[T]) Remove(node *Entry[T])
• type Queue
  • func NewQueue[T any](fun HandleFun[T], slotNum int) *Queue[T]
  • func (q *Queue[T]) Push(delay time.Duration, ele T)
  • func (q *Queue[T]) Run()

Types

type Entry

type Entry[T any] struct {
	Body  T
	Delay time.Duration
	// contains filtered or unexported fields
}

type HandleFun

type HandleFun[T any] func(ele *Entry[T])

type LinkList

type LinkList[T any] struct {
	Head *Entry[T]
	Tail *Entry[T]
	sync.Mutex
}

func (*LinkList[T]) Remove

func (ll *LinkList[T]) Remove(node *Entry[T])

type Queue

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

func NewQueue

func NewQueue[T any](fun HandleFun[T], slotNum int) *Queue[T]

func (*Queue[T]) Push

func (q *Queue[T]) Push(delay time.Duration, ele T)

func (*Queue[T]) Run

func (q *Queue[T]) Run()