delayqueue

Documentation

Index

• type DelayQueue
  • func New(size int) *DelayQueue
  • func (dq *DelayQueue) Offer(elem interface{}, expiration int64)
  • func (dq *DelayQueue) Poll(exitC chan struct{}, nowF func() int64)

Types

type DelayQueue

type DelayQueue struct {
	C chan interface{}
	// contains filtered or unexported fields
}

DelayQueue is an unbounded blocking queue of *Delayed* elements, in which an element can only be taken when its delay has expired. The head of the queue is the *Delayed* element whose delay expired furthest in the past.

func New

func New(size int) *DelayQueue

New creates an instance of delayQueue with the specified size.

func (*DelayQueue) Offer

func (dq *DelayQueue) Offer(elem interface{}, expiration int64)

Offer inserts the element into the current queue.

func (*DelayQueue) Poll

func (dq *DelayQueue) Poll(exitC chan struct{}, nowF func() int64)

Poll starts an infinite loop, in which it continually waits for an element to expire and then send the expired element to the timing wheel via the channel C.