queueEngine

Documentation

Overview

* * @Author: TheLife * @Date: 2021/5/29 下午2:38

Index

• type Engine
  • func NewEngine(chanLen int, fail ...Fail) *Engine
  • func (e *Engine) Customer(callback func(Queue) bool, finishCallbacks ...func())
  • 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, finishCallbacks ...func())

消费

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
	// contains filtered or unexported fields
}

type Queue

type Queue struct {
	Data      interface{}
	FailCount int
}