queueEngine

Documentation

Index

• type Engine
  • func NewEngine(chanLen int, fail ...Fail) *Engine
  • func (e *Engine) Customer(callback func(Queue) bool)
  • func (e *Engine) CustomerWait(callback func(Queue) bool)
  • func (e *Engine) Len() int
  • func (e *Engine) Producer(data Queue)
  • func (e *Engine) ProducerFinish()
• type Fail
• type Queue

Types

type Engine

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

func NewEngine

func NewEngine(chanLen int, fail ...Fail) *Engine

func (*Engine) Customer

func (e *Engine) Customer(callback func(Queue) bool)

消费异步

func (*Engine) CustomerWait

func (e *Engine) CustomerWait(callback func(Queue) bool)

消费

func (*Engine) Len

func (e *Engine) Len() int

等待消费数量

func (*Engine) Producer

func (e *Engine) Producer(data Queue)

生产

func (*Engine) ProducerFinish

func (e *Engine) ProducerFinish()

生产完成

type Fail

type Fail struct {
	Wait   time.Duration
	TryLen int
}

type Queue

type Queue struct {
	Data      interface{}
	FailCount int
}