container

Documentation

Index

• type DelayQueue
  • func NewDelayQueue(size int) *DelayQueue
  • func (dq *DelayQueue) Offer(elem interface{}, expiration int64)
  • func (dq *DelayQueue) Poll(exitC chan struct{}, nowF func() int64)
• type ThirdTuple
  • func NewThirdTuple[T any](first, second, third T) *ThirdTuple[T]
  • func (t *ThirdTuple[T]) String() string
• type TwoTuple
  • func NewTwoTuple[T any](first, second T) *TwoTuple[T]
  • func (t *TwoTuple[T]) String() string

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 NewDelayQueue

func NewDelayQueue(size int) *DelayQueue

NewDelayQueue 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 channel C.

type ThirdTuple

type ThirdTuple[T any] struct {
	First, Second, Third T
}

func NewThirdTuple

func NewThirdTuple[T any](first, second, third T) *ThirdTuple[T]

func (*ThirdTuple[T]) String

func (t *ThirdTuple[T]) String() string

type TwoTuple

type TwoTuple[T any] struct {
	First, Second T
}

func NewTwoTuple

func NewTwoTuple[T any](first, second T) *TwoTuple[T]

func (*TwoTuple[T]) String

func (t *TwoTuple[T]) String() string