gqueue

Documentation

Index

• type LimitQueue
  • func NewLimitQueue(limit int) *LimitQueue
  • func (q *LimitQueue) Add(item interface{})
  • func (q *LimitQueue) Clear()
  • func (q *LimitQueue) Clone() []interface{}
  • func (q *LimitQueue) Size() int
• type Queue
  • func NewQueue(concurrentSafe bool, capacity int) *Queue
  • func (q *Queue) Clear()
  • func (q *Queue) PopNoWait() (x interface{})
  • func (q *Queue) PopWait(timeout time.Duration) interface{}
  • func (q *Queue) PushNoWait(x interface{}) (err error)
  • func (q *Queue) PushWait(x interface{}, timeout time.Duration) error
  • func (q *Queue) Size() int

Types

type LimitQueue

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

func NewLimitQueue

func NewLimitQueue(limit int) *LimitQueue

func (*LimitQueue) Add

func (q *LimitQueue) Add(item interface{})

func (*LimitQueue) Clear

func (q *LimitQueue) Clear()

func (*LimitQueue) Clone

func (q *LimitQueue) Clone() []interface{}

func (*LimitQueue) Size

func (q *LimitQueue) Size() int

type Queue

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

func NewQueue

func NewQueue(concurrentSafe bool, capacity int) *Queue

capacity <= 0: unlimited capacity

func (*Queue) Clear

func (q *Queue) Clear()

func (*Queue) PopNoWait

func (q *Queue) PopNoWait() (x interface{})

func (*Queue) PopWait

func (q *Queue) PopWait(timeout time.Duration) interface{}

func (*Queue) PushNoWait

func (q *Queue) PushNoWait(x interface{}) (err error)

func (*Queue) PushWait

func (q *Queue) PushWait(x interface{}, timeout time.Duration) error

func (*Queue) Size

func (q *Queue) Size() int