queue

Documentation

Index

• type Queue
  • func NewQueue(size int) *Queue
  • func (this *Queue) Exchange(num int) (add int)
  • func (this *Queue) Init(size int) *Queue
  • func (this *Queue) Pull() interface{}
  • func (this *Queue) Push(i interface{}) bool
  • func (this *Queue) PushSlice(s []interface{})

Types

type Queue

type Queue struct {
	PoolSize int
	PoolChan chan interface{}
}

func NewQueue

func NewQueue(size int) *Queue

func (*Queue) Exchange

func (this *Queue) Exchange(num int) (add int)

二次使用Queue实例时，根据容量需求进行高效转换

func (*Queue) Init

func (this *Queue) Init(size int) *Queue

func (*Queue) Pull

func (this *Queue) Pull() interface{}

func (*Queue) Push

func (this *Queue) Push(i interface{}) bool

func (*Queue) PushSlice

func (this *Queue) PushSlice(s []interface{})