gomq

README

消息中间件操作 MQ

Documentation

Index

• type BlockingQueue
  • func NewBlockingQueue(size int) *BlockingQueue
  • func (bq *BlockingQueue) Dequeue() interface{}
  • func (bq *BlockingQueue) Enqueue(item interface{})
  • func (bq *BlockingQueue) Size() int
  • func (bq *BlockingQueue) Wait()

Types

type BlockingQueue

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

func NewBlockingQueue

func NewBlockingQueue(size int) *BlockingQueue

NewBlockingQueue 创建一个新的阻塞队列

func (*BlockingQueue) Dequeue

func (bq *BlockingQueue) Dequeue() interface{}

Dequeue 从队列中移除并返回一个元素

func (*BlockingQueue) Enqueue

func (bq *BlockingQueue) Enqueue(item interface{})

Enqueue 将元素添加到队列

func (*BlockingQueue) Size

func (bq *BlockingQueue) Size() int

Size 返回队列中的元素数量

func (*BlockingQueue) Wait

func (bq *BlockingQueue) Wait()

Wait 等待所有元素被处理