queue

Documentation

Index

• type BlockingQueue
  • func NewBlockingQueue(n int) *BlockingQueue
  • func (q *BlockingQueue) Capacity() int
  • func (q *BlockingQueue) Get(timeout time.Duration) (interface{}, bool)
  • func (q *BlockingQueue) Put(x interface{}, timeout time.Duration) bool

Types

type BlockingQueue

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

func NewBlockingQueue

func NewBlockingQueue(n int) *BlockingQueue

func (*BlockingQueue) Capacity

func (q *BlockingQueue) Capacity() int

func (*BlockingQueue) Get

func (q *BlockingQueue) Get(timeout time.Duration) (interface{}, bool)

func (*BlockingQueue) Put

func (q *BlockingQueue) Put(x interface{}, timeout time.Duration) bool