balancequeue

Documentation

Index

• type BalanceQueue
  • func New(groupNumber int) *BalanceQueue
  • func (q *BalanceQueue) Pop(e Element)
  • func (q *BalanceQueue) Push(e Element)
  • func (q *BalanceQueue) String() string
  • func (q *BalanceQueue) Update()
• type Element
  • func ElementWrapper(f func()) Element

Types

type BalanceQueue

type BalanceQueue struct {
	// contains filtered or unexported fields
}

func New

func New(groupNumber int) *BalanceQueue

New 创建一个平衡队列 groupNumber 分组数量

func (*BalanceQueue) Pop

func (q *BalanceQueue) Pop(e Element)

func (*BalanceQueue) Push

func (q *BalanceQueue) Push(e Element)

func (*BalanceQueue) String

func (q *BalanceQueue) String() string

func (*BalanceQueue) Update

func (q *BalanceQueue) Update()

type Element

type Element interface {
	BalanceQueueHandler()
}

func ElementWrapper

func ElementWrapper(f func()) Element