queue

Documentation

Index

• type Queue
  • func NewBlockQueue(max int) Queue

Types

type Queue

type Queue interface {
	// Add a element to the list tail, return false if list is full or closed
	Add(v interface{}) bool
	// Poll retrieve the element at list head
	Poll() interface{}
	// Size return the count of elements in queue
	Size() int
	// Close signal blockQueue list to avoid endless wait
	Close()
}

Queue is the FIFO data structure

func NewBlockQueue

func NewBlockQueue(max int) Queue

NewBlockQueue construct a block queue, max is the maximum elements can add into queue.