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() *Queue
  • func (q *Queue) Len() int
  • func (q *Queue) Pop() interface{}
  • func (q *Queue) Push(v interface{})
• type QueueEx
  • func NewQueueEx(concurrentSafe bool, capacity int) *QueueEx
  • func (q *QueueEx) Clear()
  • func (q *QueueEx) PopNoWait() (x interface{})
  • func (q *QueueEx) PopWait(timeout time.Duration) interface{}
  • func (q *QueueEx) PushNoWait(x interface{}) (err error)
  • func (q *QueueEx) PushWait(x interface{}, timeout time.Duration) error
  • func (q *QueueEx) 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() *Queue

func (*Queue) Len

func (q *Queue) Len() int

func (*Queue) Pop

func (q *Queue) Pop() interface{}

func (*Queue) Push

func (q *Queue) Push(v interface{})

type QueueEx

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

func NewQueueEx

func NewQueueEx(concurrentSafe bool, capacity int) *QueueEx

capacity <= 0: unlimited capacity

func (*QueueEx) Clear

func (q *QueueEx) Clear()

func (*QueueEx) PopNoWait

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

func (*QueueEx) PopWait

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

func (*QueueEx) PushNoWait

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

func (*QueueEx) PushWait

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

func (*QueueEx) Size

func (q *QueueEx) Size() int